alluxio.stress.master

Class MasterBenchTaskResult

java.lang.Object

alluxio.stress.master.MasterBenchTaskResult

All Implemented Interfaces:

TaskResult, JsonSerializable

public final class MasterBenchTaskResult
extends Object
implements TaskResult

The task result for the master stress tests.

Field Summary

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
MasterBenchTaskResult() Creates an instance.

Method Summary

Modifier and Type	Method and Description
void	addErrorMessage(String errMesssage)
TaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
long	getDurationMs()
long	getEndMs()
List<String>	getErrors()
long[]	getMaxResponseTimeNs()
MasterBenchParameters	getParameters()
long	getRecordStartMs()
MasterBenchTaskResultStatistics	getStatistics()
Map<String,MasterBenchTaskResultStatistics>	getStatisticsPerMethod()
void	incrementNumSuccess(long numSuccess) Increments the number of successes by an amount.
void	merge(MasterBenchTaskResult result) Merges (updates) a task result with this result.
void	putStatisticsForMethod(String method, MasterBenchTaskResultStatistics statistics)
void	setBaseParameters(BaseParameters baseParameters)
void	setDurationMs(long durationMs)
void	setEndMs(long endMs)
void	setErrors(List<String> errors)
void	setMaxResponseTimeNs(long[] maxResponseTimeNs)
void	setParameters(MasterBenchParameters parameters)
void	setRecordStartMs(long recordStartMs)
void	setStatistics(MasterBenchTaskResultStatistics statistics)
void	setStatisticsPerMethod(Map<String,MasterBenchTaskResultStatistics> statisticsPerMethod)

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

MasterBenchTaskResult

public MasterBenchTaskResult()

Creates an instance.

Method Detail

merge

public void merge(MasterBenchTaskResult result)
           throws Exception

Merges (updates) a task result with this result.

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)

incrementNumSuccess

public void incrementNumSuccess(long numSuccess)

Increments the number of successes by an amount.

Parameters:

numSuccess - the amount to increment by

getBaseParameters

public BaseParameters getBaseParameters()

Returns:

the base parameters

setBaseParameters

public void setBaseParameters(BaseParameters baseParameters)

Parameters:

baseParameters - the base parameters

getParameters

public MasterBenchParameters getParameters()

Returns:

the parameters

setParameters

public void setParameters(MasterBenchParameters parameters)

Parameters:

parameters - the parameters

getMaxResponseTimeNs

public long[] getMaxResponseTimeNs()

Returns:

the array of max response times (in ns)

setMaxResponseTimeNs

public void setMaxResponseTimeNs(long[] maxResponseTimeNs)

Parameters:

maxResponseTimeNs - the array of max response times (in ns)

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

Returns:

the list of errors

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

getStatistics

public MasterBenchTaskResultStatistics getStatistics()

Returns:

the statistics

setStatistics

public void setStatistics(MasterBenchTaskResultStatistics statistics)

Parameters:

statistics - the statistics

getStatisticsPerMethod

public Map<String,MasterBenchTaskResultStatistics> getStatisticsPerMethod()

Returns:

the statistics per method

setStatisticsPerMethod

public void setStatisticsPerMethod(Map<String,MasterBenchTaskResultStatistics> statisticsPerMethod)

Parameters:

statisticsPerMethod - the statistics per method

putStatisticsForMethod

public void putStatisticsForMethod(String method,
                                   MasterBenchTaskResultStatistics statistics)

Parameters:

method - the name of the method to insert statistics for

statistics - the statistics for the method

aggregator

public TaskResult.Aggregator aggregator()

Specified by:

aggregator in interface TaskResult

Returns:

the aggregator that can produce a summary