alluxio.stress.fuse

Class FuseIOTaskResult

java.lang.Object

alluxio.stress.fuse.FuseIOTaskResult

All Implemented Interfaces:

TaskResult, JsonSerializable

public final class FuseIOTaskResult
extends Object
implements TaskResult

The task result for the Fuse IO stress tests.

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	addErrorMessage(String errMessage)
TaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
long	getDurationMs()
long	getEndMs()
List<String>	getErrors()
long	getIOBytes()
float	getIOMBps()
FuseIOParameters	getParameters()
long	getRecordStartMs()
void	incrementIOBytes(long ioBytes) Increments the bytes of IO an amount.
void	merge(FuseIOTaskResult result) Merges this thread result into the Fuse IO task result.
void	setBaseParameters(BaseParameters baseParameters)
void	setDurationMs(long durationMs)
void	setEndMs(long endMs)
void	setErrors(List<String> errors)
void	setIOBytes(long ioBytes)
void	setIOMBps(float ioMBps)
void	setParameters(FuseIOParameters parameters)
void	setRecordStartMs(long recordStartMs)

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

aggregator

public TaskResult.Aggregator aggregator()

Specified by:

aggregator in interface TaskResult

Returns:

the aggregator that can produce a summary

merge

public void merge(FuseIOTaskResult result)

Merges this thread result into the Fuse IO task result.

Parameters:

result - the result to merge

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

Returns:

the Fuse IO Stress Bench parameters

setParameters

public void setParameters(FuseIOParameters parameters)

Parameters:

parameters - the Fuse IO Stress Bench parameters

getDurationMs

public long getDurationMs()

Returns:

the duration (in ms)

setDurationMs

public void setDurationMs(long durationMs)

Parameters:

durationMs - the duration (in ms)

getIOBytes

public long getIOBytes()

Returns:

bytes of IO

incrementIOBytes

public void incrementIOBytes(long ioBytes)

Increments the bytes of IO an amount.

Parameters:

ioBytes - the amount to increment by

setIOBytes

public void setIOBytes(long ioBytes)

Parameters:

ioBytes - bytes of IO

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

Parameters:

errMessage - the error message to add

getIOMBps

public float getIOMBps()

Returns:

the throughput (MB/s)

setIOMBps

public void setIOMBps(float ioMBps)

Parameters:

ioMBps - the throughput (MB / s)