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	addErrorMessage(String errMesssage)
void	aggregateByWorker(WorkerBenchTaskResult result) Merges (updates) a task result with this result except the error information.
TaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
long	getEndMs()
List<String>	getErrors()
long	getIOBytes()
WorkerBenchParameters	getParameters()
long	getRecordStartMs()
void	incrementIOBytes(long ioBytes) Increments the bytes of IO an amount.
void	merge(WorkerBenchTaskResult result) Merges (updates) a task result with this result.
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)

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

addErrorMessage

public void addErrorMessage(String errMesssage)

Parameters:

errMesssage - the error message to add

aggregator

public TaskResult.Aggregator aggregator()

Specified by:

aggregator in interface TaskResult

Returns:

the aggregator that can produce a summary