alluxio.stress.client

Class ClientIOTaskResult

java.lang.Object

alluxio.stress.client.ClientIOTaskResult

All Implemented Interfaces:

Summary, TaskResult, JsonSerializable

public final class ClientIOTaskResult
extends Object
implements TaskResult, Summary

The task result for the master stress tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClientIOTaskResult.GraphGenerator The graph generator for this summary.
static class	ClientIOTaskResult.ThreadCountResult A result for a single thread count test.

Field Summary

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
ClientIOTaskResult() Creates an instance.

Method Summary

Modifier and Type	Method and Description
void	addThreadCountResults(int threadCount, ClientIOTaskResult.ThreadCountResult threadCountResult)
TaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
long	getEndMs()
List<String>	getErrors()
ClientIOParameters	getParameters()
long	getRecordStartMs()
Map<Integer,ClientIOTaskResult.ThreadCountResult>	getThreadCountResults()
Map<Integer,Map<String,SummaryStatistics>>	getTimeToFirstBytePerThread()
GraphGenerator	graphGenerator()
void	putTimeToFirstBytePerThread(Integer numThreads, Map<String,SummaryStatistics> statistics)
void	setBaseParameters(BaseParameters baseParameters)
void	setEndMs(long endMs)
void	setParameters(ClientIOParameters parameters)
void	setRecordStartMs(long recordStartMs)
void	setThreadCountResults(Map<Integer,ClientIOTaskResult.ThreadCountResult> threadCountResults)
void	setTimeToFirstBytePerThread(Map<Integer,Map<String,SummaryStatistics>> timeToFirstByte)

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

ClientIOTaskResult

public ClientIOTaskResult()

Creates an instance.

Method Detail

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

Returns:

the parameters

setParameters

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

getTimeToFirstBytePerThread

public Map<Integer,Map<String,SummaryStatistics>> getTimeToFirstBytePerThread()

Returns:

client IO statistics per method

setTimeToFirstBytePerThread

public void setTimeToFirstBytePerThread(Map<Integer,Map<String,SummaryStatistics>> timeToFirstByte)

Parameters:

timeToFirstByte - time to first statistics

putTimeToFirstBytePerThread

public void putTimeToFirstBytePerThread(Integer numThreads,
                                        Map<String,SummaryStatistics> statistics)

Parameters:

numThreads - thread count

statistics - ClientIOTaskResultStatistics

getEndMs

public long getEndMs()

Returns:

the end time (in ms)

setEndMs

public void setEndMs(long endMs)

Parameters:

endMs - the end time (in ms)

getThreadCountResults

public Map<Integer,ClientIOTaskResult.ThreadCountResult> getThreadCountResults()

Returns:

the map of thread counts to results

setThreadCountResults

public void setThreadCountResults(Map<Integer,ClientIOTaskResult.ThreadCountResult> threadCountResults)

Parameters:

threadCountResults - the map of thread counts to results

addThreadCountResults

public void addThreadCountResults(int threadCount,
                                  ClientIOTaskResult.ThreadCountResult threadCountResult)

Parameters:

threadCount - the thread count of the results

threadCountResult - the results to add

getErrors

public List<String> getErrors()

Specified by:

getErrors in interface TaskResult

Returns:

the list of errors in the result

aggregator

public TaskResult.Aggregator aggregator()

Specified by:

aggregator in interface TaskResult

Returns:

the aggregator that can produce a summary

graphGenerator

public GraphGenerator graphGenerator()

Specified by:

graphGenerator in interface Summary

Returns:

the graph generator for this type of summary