alluxio.stress.worker

Class WorkerBenchSummary

java.lang.Object

alluxio.stress.common.GeneralBenchSummary<WorkerBenchTaskResult>

alluxio.stress.worker.WorkerBenchSummary

All Implemented Interfaces:

Summary, JsonSerializable

public final class WorkerBenchSummary
extends GeneralBenchSummary<WorkerBenchTaskResult>

The summary for the worker stress tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WorkerBenchSummary.GraphGenerator The graph generator for this summary.

Field Summary

Fields inherited from class alluxio.stress.common.GeneralBenchSummary

mNodeResults, mThroughput

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
WorkerBenchSummary() Creates an instance.
WorkerBenchSummary(WorkerBenchTaskResult mergedTaskResults, Map<String,WorkerBenchTaskResult> nodes) Creates an instance.

Method Summary

Modifier and Type	Method and Description
long	getDurationMs()
long	getEndTimeMs()
long	getIOBytes()
float	getIOMBps()
WorkerBenchParameters	getParameters()
List<Long>	getThroughputPercentiles()
GraphGenerator	graphGenerator()
void	setDurationMs(long durationMs)
void	setEndTimeMs(long endTimeMs)
void	setIOBytes(long IOBytes)
void	setIOMBps(float ioMBps)
void	setParameters(WorkerBenchParameters parameters)
void	setThroughputPercentiles(List<Long> percentiles)

Methods inherited from class alluxio.stress.common.GeneralBenchSummary

collectErrorsFromAllNodes, getNodeResults, getThroughput, setNodeResults, setThroughput

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

WorkerBenchSummary

public WorkerBenchSummary()

Creates an instance. Default constructor required for json deserialization.

WorkerBenchSummary

public WorkerBenchSummary(WorkerBenchTaskResult mergedTaskResults,
                          Map<String,WorkerBenchTaskResult> nodes)

Creates an instance.

Parameters:

mergedTaskResults - the merged task result

nodes - the list of nodes

Method Detail

getIOMBps

public float getIOMBps()

Returns:

the throughput (MB/s)

setIOMBps

public void setIOMBps(float ioMBps)

Parameters:

ioMBps - the throughput (MB / s)

getDurationMs

public long getDurationMs()

Returns:

the duration (in ms)

setDurationMs

public void setDurationMs(long durationMs)

Parameters:

durationMs - the duration (in ms)

getParameters

public WorkerBenchParameters getParameters()

Returns:

the parameters

setParameters

public void setParameters(WorkerBenchParameters parameters)

Parameters:

parameters - the parameters

getEndTimeMs

public long getEndTimeMs()

Returns:

the end time (in ms)

setEndTimeMs

public void setEndTimeMs(long endTimeMs)

Parameters:

endTimeMs - the end time (in ms)

getIOBytes

public long getIOBytes()

Returns:

number of bytes

setIOBytes

public void setIOBytes(long IOBytes)

Parameters:

IOBytes - the number of bytes

getThroughputPercentiles

public List<Long> getThroughputPercentiles()

Returns:

0~100 percentiles of recorded durations

setThroughputPercentiles

public void setThroughputPercentiles(List<Long> percentiles)

Parameters:

percentiles - a list of calculated percentiles from recorded durations

graphGenerator

public GraphGenerator graphGenerator()

Returns:

the graph generator for this type of summary