alluxio.stress.jobservice

Class JobServiceBenchTaskResult

java.lang.Object

alluxio.stress.jobservice.JobServiceBenchTaskResult

All Implemented Interfaces:

TaskResult, JsonSerializable

public final class JobServiceBenchTaskResult
extends Object
implements TaskResult

The task result for the job service stress tests.

Field Summary

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
JobServiceBenchTaskResult() Creates an instance.

Method Summary

Modifier and Type	Method and Description
void	addErrorMessage(String errMesssage)
void	aggregateByWorker(JobServiceBenchTaskResult result) Merges (updates) a task result with this result except the error information.
TaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
long	getEndMs()
List<String>	getErrors()
long[]	getMaxResponseTimeNs()
JobServiceBenchParameters	getParameters()
long	getRecordStartMs()
JobServiceBenchTaskResultStatistics	getStatistics()
Map<String,JobServiceBenchTaskResultStatistics>	getStatisticsPerMethod()
void	incrementNumSuccess(long numSuccess) Increments the number of successes by an amount.
void	merge(JobServiceBenchTaskResult result) Merges (updates) a task result with this result.
void	putStatisticsForMethod(String method, JobServiceBenchTaskResultStatistics statistics)
void	setBaseParameters(BaseParameters baseParameters)
void	setEndMs(long endMs)
void	setErrors(List<String> errors)
void	setMaxResponseTimeNs(long[] maxResponseTimeNs)
void	setParameters(JobServiceBenchParameters parameters)
void	setRecordStartMs(long recordStartMs)
void	setStatistics(JobServiceBenchTaskResultStatistics statistics)
void	setStatisticsPerMethod(Map<String,JobServiceBenchTaskResultStatistics> 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

JobServiceBenchTaskResult

public JobServiceBenchTaskResult()

Creates an instance.

Method Detail

merge

public void merge(JobServiceBenchTaskResult result)
           throws Exception

Merges (updates) a task result with this result.

Parameters:

result - the task result to merge

Throws:

Exception

aggregateByWorker

public void aggregateByWorker(JobServiceBenchTaskResult result)
                       throws Exception

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

Parameters:

result - the task result to merge

Throws:

Exception

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

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

Returns:

the parameters

setParameters

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

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

getStatistics

public JobServiceBenchTaskResultStatistics getStatistics()

Returns:

the statistics

setStatistics

public void setStatistics(JobServiceBenchTaskResultStatistics statistics)

Parameters:

statistics - the statistics

getStatisticsPerMethod

public Map<String,JobServiceBenchTaskResultStatistics> getStatisticsPerMethod()

Returns:

the statistics per method

setStatisticsPerMethod

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

Parameters:

statisticsPerMethod - the statistics per method

putStatisticsForMethod

public void putStatisticsForMethod(String method,
                                   JobServiceBenchTaskResultStatistics 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