alluxio.stress.common

Class AbstractMaxThroughputSummary<T extends Parameters,S extends GeneralBenchSummary>

java.lang.Object

alluxio.stress.common.AbstractMaxThroughputSummary<T,S>

Type Parameters:

T - the stress bench parameter

S - the Bench Summary

All Implemented Interfaces:

Summary, TaskResult, JsonSerializable

Direct Known Subclasses:

JobServiceMaxThroughputSummary, MasterMaxThroughputSummary

public abstract class AbstractMaxThroughputSummary<T extends Parameters,S extends GeneralBenchSummary>
extends Object
implements Summary, TaskResult

abstract class for result of MaxThroughput stressBench.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractMaxThroughputSummary.GraphGenerator The graph generator for this summary.

Nested classes/interfaces inherited from interface alluxio.stress.TaskResult

TaskResult.Aggregator<T extends TaskResult>

Field Summary

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
AbstractMaxThroughputSummary() Creates an instance.

Method Summary

Modifier and Type	Method and Description
void	addFailedRun(long targetThroughput, S summary) Adds a failing run to the summary, for a target throughput.
void	addPassedRun(long targetThroughput, S summary) Adds a passing run to the summary, for a target throughput.
TaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
long	getEndTimeMs()
List<String>	getErrors()
Map<Long,S>	getFailedRuns()
float	getMaxThroughput()
T	getParameters()
Map<Long,S>	getPassedRuns()
GraphGenerator	graphGenerator()
void	setEndTimeMs(long endTimeMs)
void	setFailedRuns(Map<Long,S> failedRuns)
void	setMaxThroughput(float maxThroughput)
void	setParameters(T parameters)
void	setPassedRuns(Map<Long,S> passedRuns)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface alluxio.util.JsonSerializable

fromJson, fromJson, getClassName, setClassName, toJson

Constructor Detail

AbstractMaxThroughputSummary

public AbstractMaxThroughputSummary()

Creates an instance.

Method Detail

getMaxThroughput

public float getMaxThroughput()

Returns:

the max throughput

setMaxThroughput

public void setMaxThroughput(float maxThroughput)

Parameters:

maxThroughput - the max throughput

getEndTimeMs

public long getEndTimeMs()

Returns:

the end time (in ms)

setEndTimeMs

public void setEndTimeMs(long endTimeMs)

Parameters:

endTimeMs - the end time (in ms)

graphGenerator

public GraphGenerator graphGenerator()

Specified by:

graphGenerator in interface Summary

Returns:

the graph generator for this type of summary

getParameters

public T getParameters()

Returns:

the parameters

setParameters

public void setParameters(T parameters)

Parameters:

parameters - the parameters

addPassedRun

public void addPassedRun(long targetThroughput,
                         S summary)

Adds a passing run to the summary, for a target throughput.

Parameters:

targetThroughput - the target throughput

summary - the summary

getPassedRuns

public Map<Long,S> getPassedRuns()

Returns:

the Map(target throughput -> summary) of passed runs

setPassedRuns

public void setPassedRuns(Map<Long,S> passedRuns)

Parameters:

passedRuns - the Map(target throughput -> summary) of passed runs

addFailedRun

public void addFailedRun(long targetThroughput,
                         S summary)

Adds a failing run to the summary, for a target throughput.

Parameters:

targetThroughput - the target throughput

summary - the summary

getFailedRuns

public Map<Long,S> getFailedRuns()

Returns:

the Map(target throughput -> summary) of failed runs

setFailedRuns

public void setFailedRuns(Map<Long,S> failedRuns)

Parameters:

failedRuns - the Map(target throughput -> summary) of failed runs

aggregator

public TaskResult.Aggregator aggregator()

Specified by:

aggregator in interface TaskResult

Returns:

the aggregator that can produce a summary

getErrors

public List<String> getErrors()

Specified by:

getErrors in interface TaskResult

Returns:

the list of errors in the result

getBaseParameters

public BaseParameters getBaseParameters()

Specified by:

getBaseParameters in interface TaskResult

Returns:

the base parameters of the result