alluxio.stress.cli

Class StreamRegisterWorkerBench

java.lang.Object

alluxio.stress.cli.Benchmark<RpcTaskResult>

alluxio.stress.cli.RpcBench<BlockMasterBenchParameters>

alluxio.stress.cli.StreamRegisterWorkerBench

public class StreamRegisterWorkerBench
extends RpcBench<BlockMasterBenchParameters>

A benchmarking tool for the RegisterWorkerStream RPC.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.stress.cli.Benchmark

Benchmark.MethodStatistics, Benchmark.ProfileInput

Field Summary

Fields inherited from class alluxio.stress.cli.RpcBench

mPool

Fields inherited from class alluxio.stress.cli.Benchmark

mBaseParameters

Constructor Summary

Constructors

Constructor and Description
StreamRegisterWorkerBench()

Method Summary

Modifier and Type	Method and Description
String	getBenchDescription() Get the description of the bench.
BlockMasterBenchParameters	getParameters() Returns the parameters.
static void	main(String[] args)
void	prepare() Prepares to run the test.
RpcTaskResult	runRPC() Defines how each thread runs RPCs.

Methods inherited from class alluxio.stress.cli.RpcBench

cleanup, getPool, runLocal

Methods inherited from class alluxio.stress.cli.Benchmark

generateJobConfig, mainInternal, processMethodProfiles, run

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamRegisterWorkerBench

public StreamRegisterWorkerBench()

Method Detail

getBenchDescription

public String getBenchDescription()

Description copied from class: Benchmark

Get the description of the bench.

Specified by:

getBenchDescription in class Benchmark<RpcTaskResult>

Returns:

string of the bench description

prepare

public void prepare()
             throws Exception

Description copied from class: Benchmark

Prepares to run the test.

Specified by:

prepare in class Benchmark<RpcTaskResult>

Throws:

Exception

main

public static void main(String[] args)

Parameters:

args - command-line arguments

runRPC

public RpcTaskResult runRPC()
                     throws Exception

Description copied from class: RpcBench

Defines how each thread runs RPCs.

Specified by:

runRPC in class RpcBench<BlockMasterBenchParameters>

Returns:

the results of RPC runs

Throws:

Exception

getParameters

public BlockMasterBenchParameters getParameters()

Description copied from class: RpcBench

Returns the parameters.

Specified by:

getParameters in class RpcBench<BlockMasterBenchParameters>

Returns:

the parameters for the benchmark class