alluxio.stress.worker

Class WorkerBenchTaskResult

java.lang.Object

alluxio.stress.worker.WorkerBenchTaskResult

All Implemented Interfaces:

TaskResult, JsonSerializable

public final class WorkerBenchTaskResult
extends Object
implements TaskResult

The task results for the worker stress test.

Field Summary

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
WorkerBenchTaskResult() Creates an instance.

Method Summary

Modifier and Type	Method and Description
void	addDataPoint(WorkerBenchCoarseDataPoint point)
void	addDataPoints(Collection<WorkerBenchCoarseDataPoint> stats)
void	addErrorMessage(String errMessage)
void	aggregateByWorker(WorkerBenchTaskResult result) Merges (updates) a task result with this result except the error information.
TaskResult.Aggregator	aggregator()
void	calculatePercentiles() From the collected operation data, calculates 100 percentiles.
void	clearAllThroughput() Clears all data points from the result.
List<Long>	getAllThroughput()
BaseParameters	getBaseParameters()
List<WorkerBenchCoarseDataPoint>	getDataPoints()
long	getEndMs()
List<String>	getErrors()
long	getIOBytes()
WorkerBenchParameters	getParameters()
long	getRecordStartMs()
List<Long>	getThroughputPercentiles()
void	incrementIOBytes(long ioBytes) Increments the bytes of IO an amount.
void	merge(WorkerBenchTaskResult result) Merges (updates) a task result with this result.
void	setAllThroughput(List<Long> allThroughputValues)
void	setBaseParameters(BaseParameters baseParameters)
void	setEndMs(long endMs)
void	setErrors(List<String> errors)
void	setIOBytes(long ioBytes)
void	setParameters(WorkerBenchParameters parameters)
void	setRecordStartMs(long recordStartMs)
void	setThroughputPercentiles(List<Long> percentiles)

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

WorkerBenchTaskResult

public WorkerBenchTaskResult()

Creates an instance.

Method Detail

merge

public void merge(WorkerBenchTaskResult result)
           throws Exception

Merges (updates) a task result with this result.

Parameters:

result - the task result to merge

Throws:

Exception

aggregateByWorker

public void aggregateByWorker(WorkerBenchTaskResult result)

Merges (updates) a task result with this result except the error information.

Parameters:

result - the task result to merge

getIOBytes

public long getIOBytes()

Returns:

bytes of IO

incrementIOBytes

public void incrementIOBytes(long ioBytes)

Increments the bytes of IO an amount.

Parameters:

ioBytes - the amount to increment by

setIOBytes

public void setIOBytes(long ioBytes)

Parameters:

ioBytes - bytes of IO

getBaseParameters

public BaseParameters getBaseParameters()

Specified by:

getBaseParameters in interface TaskResult

Returns:

the base parameters of the result

setBaseParameters

public void setBaseParameters(BaseParameters baseParameters)

Parameters:

baseParameters - the base parameters

getParameters

public WorkerBenchParameters getParameters()

Returns:

the parameters

setParameters

public void setParameters(WorkerBenchParameters parameters)

Parameters:

parameters - the parameters

getRecordStartMs

public long getRecordStartMs()

Returns:

the start time (in ms)

setRecordStartMs

public void setRecordStartMs(long recordStartMs)

Parameters:

recordStartMs - the start time (in ms)

getEndMs

public long getEndMs()

Returns:

the end time (in ms)

setEndMs

public void setEndMs(long endMs)

Parameters:

endMs - the end time (in ms)

getErrors

public List<String> getErrors()

Specified by:

getErrors in interface TaskResult

Returns:

the list of errors in the result

setErrors

public void setErrors(List<String> errors)

Parameters:

errors - the list of errors

getThroughputPercentiles

public List<Long> getThroughputPercentiles()

Returns:

100 percentiles for durations of all I/O operations

setThroughputPercentiles

public void setThroughputPercentiles(List<Long> percentiles)

Parameters:

percentiles - 100 percentiles for durations of all I/O operations

getAllThroughput

public List<Long> getAllThroughput()

Returns:

all instant throughput values of I/O operations

setAllThroughput

public void setAllThroughput(List<Long> allThroughputValues)

Parameters:

allThroughputValues - all instant throughput values of I/O operations

calculatePercentiles

public void calculatePercentiles()

From the collected operation data, calculates 100 percentiles.

addErrorMessage

public void addErrorMessage(String errMessage)

Parameters:

errMessage - the error message to add

getDataPoints

public List<WorkerBenchCoarseDataPoint> getDataPoints()

Returns:

all data points for I/O operations

addDataPoint

public void addDataPoint(WorkerBenchCoarseDataPoint point)

Parameters:

point - one data point for one I/O operation

addDataPoints

public void addDataPoints(Collection<WorkerBenchCoarseDataPoint> stats)

Parameters:

stats - data points for all recorded I/O operations

clearAllThroughput

public void clearAllThroughput()

Clears all data points from the result.

aggregator

public TaskResult.Aggregator aggregator()

Specified by:

aggregator in interface TaskResult

Returns:

the aggregator that can produce a summary