alluxio.stress.master

Class MasterBenchTaskResultBase<P extends MasterBenchBaseParameters>

java.lang.Object

alluxio.stress.master.MasterBenchTaskResultBase<P>

Type Parameters:

P - the type of task parameter

All Implemented Interfaces:

TaskResult, JsonSerializable

Direct Known Subclasses:

MasterBenchTaskResult, MultiOperationMasterBenchTaskResult

public abstract class MasterBenchTaskResultBase<P extends MasterBenchBaseParameters>
extends Object
implements TaskResult

The task result for the master stress tests.

Nested Class Summary

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

TaskResult.Aggregator<T extends TaskResult>

Field Summary

Fields

Modifier and Type	Field and Description
protected BaseParameters	mBaseParameters
protected long	mDurationMs
protected long	mEndMs
protected List<String>	mErrors
protected P	mParameters
protected long	mRecordStartMs

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
MasterBenchTaskResultBase() Creates an instance.

Method Summary

Modifier and Type	Method and Description
void	addErrorMessage(String errMesssage)
void	aggregateByWorker(MasterBenchTaskResultBase<P> result) Merges (updates) a task result with this result except the error information.
BaseParameters	getBaseParameters()
long	getDurationMs()
long	getEndMs()
List<String>	getErrors()
P	getParameters()
long	getRecordStartMs()
void	merge(MasterBenchTaskResultBase<P> result) Merges (updates) a task result with this result.
abstract void	putStatisticsForMethod(String method, MasterBenchTaskResultStatistics statistics)
void	setBaseParameters(BaseParameters baseParameters)
void	setDurationMs(long durationMs)
void	setEndMs(long endMs)
void	setErrors(List<String> errors)
void	setParameters(P 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.stress.TaskResult

aggregator

Methods inherited from interface alluxio.util.JsonSerializable

fromJson, fromJson, getClassName, setClassName, toJson

Field Detail

mRecordStartMs

protected long mRecordStartMs

mEndMs

protected long mEndMs

mDurationMs

protected long mDurationMs

mBaseParameters

protected BaseParameters mBaseParameters

mParameters

protected P extends MasterBenchBaseParameters mParameters

mErrors

protected List<String> mErrors

Constructor Detail

MasterBenchTaskResultBase

public MasterBenchTaskResultBase()

Creates an instance.

Method Detail

merge

public void merge(MasterBenchTaskResultBase<P> result)
           throws Exception

Merges (updates) a task result with this result.

Parameters:

result - the task result to merge

Throws:

Exception

putStatisticsForMethod

public abstract void putStatisticsForMethod(String method,
                                            MasterBenchTaskResultStatistics statistics)

Parameters:

method - the name of the method to insert statistics for

statistics - the statistics for the method

aggregateByWorker

public void aggregateByWorker(MasterBenchTaskResultBase<P> result)
                       throws Exception

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

Parameters:

result - the task result to merge

Throws:

Exception

getDurationMs

public long getDurationMs()

Returns:

the duration (in ms)

setDurationMs

public void setDurationMs(long durationMs)

Parameters:

durationMs - the duration (in ms)

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 P getParameters()

Returns:

the parameters

setParameters

public void setParameters(P 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