alluxio.stress.fuse

Class FuseIOTaskResult

java.lang.Object

alluxio.stress.fuse.FuseIOTaskResult

All Implemented Interfaces:

Summary, TaskResult, JsonSerializable

public final class FuseIOTaskResult
extends Object
implements TaskResult, Summary

The task result for the Fuse IO stress tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FuseIOTaskResult.GraphGenerator The graph generator for this summary.
static class	FuseIOTaskResult.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
FuseIOTaskResult() Creates an instance.

Method Summary

Modifier and Type	Method and Description
void	addThreadCountResults(int threadCount, FuseIOTaskResult.ThreadCountResult threadCountResult)
TaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
long	getEndMs()
FuseIOParameters	getParameters()
long	getRecordStartMs()
Map<Integer,FuseIOTaskResult.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(FuseIOParameters parameters)
void	setRecordStartMs(long recordStartMs)
void	setThreadCountResults(Map<Integer,FuseIOTaskResult.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

FuseIOTaskResult

public FuseIOTaskResult()

Creates an instance.

Method Detail

getBaseParameters

public BaseParameters getBaseParameters()

Returns:

the base parameters

setBaseParameters

public void setBaseParameters(BaseParameters baseParameters)

Parameters:

baseParameters - the base parameters

getParameters

public FuseIOParameters getParameters()

Returns:

the Fuse IO parameters

setParameters

public void setParameters(FuseIOParameters parameters)

Parameters:

parameters - the Fuse IO 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 - FuseIOTaskResultStatistics

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,FuseIOTaskResult.ThreadCountResult> getThreadCountResults()

Returns:

the map of thread counts to results

setThreadCountResults

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

Parameters:

threadCountResults - the map of thread counts to results

addThreadCountResults

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

Parameters:

threadCount - the thread count of the results

threadCountResult - the results to add

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