alluxio.stress.rpc

Class RpcTaskResult

java.lang.Object

alluxio.stress.rpc.RpcTaskResult

All Implemented Interfaces:

TaskResult, JsonSerializable

public class RpcTaskResult
extends Object
implements TaskResult

This object holds the results from one RPC benchmark test run, containing all successful and failed RPCs. For a successful RPC call, the result is a data point. For a failed RPC call, the result is an error.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RpcTaskResult.Aggregator An aggregator that merges multiple RpcTaskResult.
static class	RpcTaskResult.Point Each point stands for one successful RPC.

Field Summary

Fields inherited from interface alluxio.util.JsonSerializable

CLASS_NAME_FIELD

Constructor Summary

Constructors

Constructor and Description
RpcTaskResult() Constructor.
RpcTaskResult(BaseParameters baseParameters, RpcBenchParameters rpcBenchParameters) Constructor with only parameters.
RpcTaskResult(RpcTaskResult source) A copy constructor.

Method Summary

Modifier and Type	Method and Description
void	addError(String errorMsg)
void	addPoint(RpcTaskResult.Point p)
RpcTaskResult.Aggregator	aggregator()
BaseParameters	getBaseParameters()
List<String>	getErrors()
RpcBenchParameters	getParameters()
List<RpcTaskResult.Point>	getPoints()
void	merge(RpcTaskResult r)
void	setBaseParameters(BaseParameters baseParameters)
void	setErrors(List<String> errors)
void	setParameters(RpcBenchParameters parameters)
void	setPoints(List<RpcTaskResult.Point> points)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface alluxio.util.JsonSerializable

fromJson, fromJson, getClassName, setClassName, toJson

Constructor Detail

RpcTaskResult

public RpcTaskResult()

Constructor.

RpcTaskResult

public RpcTaskResult(BaseParameters baseParameters,
                     RpcBenchParameters rpcBenchParameters)

Constructor with only parameters.

Parameters:

baseParameters - base parameters

rpcBenchParameters - test specific parameters

RpcTaskResult

public RpcTaskResult(RpcTaskResult source)

A copy constructor.

Parameters:

source - the result to copy from

Method Detail

getBaseParameters

@Nullable
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 BaseParameters to use

getParameters

@Nullable
public RpcBenchParameters getParameters()

Returns:

the RpcBenchParameters

setParameters

public void setParameters(RpcBenchParameters parameters)

Parameters:

parameters - the RpcBenchParameters to use

addError

public void addError(String errorMsg)

Parameters:

errorMsg - an error msg to add

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 errors

addPoint

public void addPoint(RpcTaskResult.Point p)

Parameters:

p - the data point to add to the results

getPoints

public List<RpcTaskResult.Point> getPoints()

Returns:

all data points from successful RPCs

setPoints

public void setPoints(List<RpcTaskResult.Point> points)

Parameters:

points - data points

aggregator

public RpcTaskResult.Aggregator aggregator()

Specified by:

aggregator in interface TaskResult

Returns:

the aggregator that can produce a summary

merge

public void merge(RpcTaskResult r)

Parameters:

r - another result to merge into this one

toString

public String toString()

Overrides:

toString in class Object