alluxio.stress.fuse

Class FuseIOSummary

java.lang.Object

alluxio.stress.fuse.FuseIOSummary

All Implemented Interfaces:

Summary, JsonSerializable

public class FuseIOSummary
extends Object
implements Summary

The summary for Fuse IO stress bench.

Field Summary

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
FuseIOSummary() Default constructor required for json deserialization.
FuseIOSummary(FuseIOParameters parameters, BaseParameters baseParameters, List<String> nodes, Map<String,List<String>> errors, long recordStartMs, long endMs, long ioBytes, float ioMBps, Map<String,Float> clientsThroughput) Creates an instance.

Method Summary

Modifier and Type	Method and Description
BaseParameters	getBaseParameters()
Map<String,Float>	getClientsThroughput()
long	getEndMs()
Map<String,List<String>>	getErrors()
long	getIOBytes()
float	getIOMBps()
List<String>	getNodes()
FuseIOParameters	getParameters()
long	getRecordStartMs()
GraphGenerator	graphGenerator()
void	setBaseParameters(BaseParameters baseParameters)
void	setClientsThroughput(Map<String,Float> clientsThroughput)
void	setEndMs(long endMs)
void	setErrors(Map<String,List<String>> errors)
void	setIOBytes(long ioBytes)
void	setIOMBps(float ioMBps)
void	setNodes(List<String> nodes)
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

FuseIOSummary

public FuseIOSummary()

Default constructor required for json deserialization.

FuseIOSummary

public FuseIOSummary(FuseIOParameters parameters,
                     BaseParameters baseParameters,
                     List<String> nodes,
                     Map<String,List<String>> errors,
                     long recordStartMs,
                     long endMs,
                     long ioBytes,
                     float ioMBps,
                     Map<String,Float> clientsThroughput)

Creates an instance.

Parameters:

parameters - the parameters for the Fuse IO stress bench

baseParameters - the base parameters for the Fuse IO stress bench

nodes - the unique ids of all job workers

errors - all errors reported by job workers

recordStartMs - the timestamp starting counting bytes

endMs - the timestamp that the test ends

ioBytes - total number of bytes processed by workers

ioMBps - aggregated throughput data

clientsThroughput - the throughput data of each job worker

Method Detail

graphGenerator

@Nullable
public GraphGenerator graphGenerator()

Specified by:

graphGenerator in interface Summary

Returns:

the graph generator for this type of summary

getClientsThroughput

public Map<String,Float> getClientsThroughput()

Returns:

a map mapping job worker unique id to its throughput

setClientsThroughput

public void setClientsThroughput(Map<String,Float> clientsThroughput)

Parameters:

clientsThroughput - the map mapping job worker unique id to its throughput

getNodes

public List<String> getNodes()

Returns:

the list of the unique ids of job workers

setNodes

public void setNodes(List<String> nodes)

Parameters:

nodes - the list of the unique ids of job workers

getErrors

public Map<String,List<String>> getErrors()

Returns:

the list of errors

setErrors

public void setErrors(Map<String,List<String>> errors)

Parameters:

errors - the list of errors

getParameters

public FuseIOParameters getParameters()

Returns:

Fuse IO stress bench parameters

setParameters

public void setParameters(FuseIOParameters parameters)

Parameters:

parameters - Fuse IO stress bench parameters

getBaseParameters

public BaseParameters getBaseParameters()

Returns:

the base parameters

setBaseParameters

public void setBaseParameters(BaseParameters baseParameters)

Parameters:

baseParameters - the base parameters

getRecordStartMs

public long getRecordStartMs()

Returns:

the timestamp starting counting bytes (in ms)

setRecordStartMs

public void setRecordStartMs(long recordStartMs)

Parameters:

recordStartMs - the timestamp starting counting bytes (in ms)

getEndMs

public long getEndMs()

Returns:

the timestamp that test ends (in ms)

setEndMs

public void setEndMs(long endMs)

Parameters:

endMs - the timestamp that test ends (in ms)

getIOBytes

public long getIOBytes()

Returns:

total number of bytes processed during test time

setIOBytes

public void setIOBytes(long ioBytes)

Parameters:

ioBytes - total number of bytes processed during test time

getIOMBps

public float getIOMBps()

Returns:

overall throughput (in MB / s)

setIOMBps

public void setIOMBps(float ioMBps)

Parameters:

ioMBps - overall throughput (in MB / s)