alluxio.stress.cli

Class RpcBench<T extends RpcBenchParameters>

java.lang.Object

alluxio.stress.cli.Benchmark<RpcTaskResult>

alluxio.stress.cli.RpcBench<T>

Type Parameters:

T - the child RpcBenchParameters type

Direct Known Subclasses:

GetPinnedFileIdsBench, RegisterWorkerBench, StreamRegisterWorkerBench, WorkerHeartbeatBench

public abstract class RpcBench<T extends RpcBenchParameters>
extends Benchmark<RpcTaskResult>

A benchmarking tool to simulate stress on RPCs.

Nested Class Summary

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

Benchmark.MethodStatistics, Benchmark.ProfileInput

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutorService	mPool

Fields inherited from class alluxio.stress.cli.Benchmark

mBaseParameters

Constructor Summary

Constructors

Constructor and Description
RpcBench()

Method Summary

Modifier and Type	Method and Description
void	cleanup() Perform post-run cleanups.
abstract T	getParameters() Returns the parameters.
ExecutorService	getPool() If the thread pool is not yet initialized, creates the pool.
RpcTaskResult	runLocal() Runs the test locally, in process.
abstract RpcTaskResult	runRPC() Defines how each thread runs RPCs.

Methods inherited from class alluxio.stress.cli.Benchmark

generateJobConfig, getBenchDescription, mainInternal, parseParameters, prepare, processMethodProfiles, run, runSingleTask

Methods inherited from class java.lang.Object

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

Field Detail

mPool

protected ExecutorService mPool

Constructor Detail

RpcBench

public RpcBench()

Method Detail

runRPC

public abstract RpcTaskResult runRPC()
                              throws Exception

Defines how each thread runs RPCs.

Returns:

the results of RPC runs

Throws:

Exception

getParameters

public abstract T getParameters()

Returns the parameters.

Returns:

the parameters for the benchmark class

getPool

public ExecutorService getPool()

If the thread pool is not yet initialized, creates the pool.

Returns:

the thread pool

cleanup

public void cleanup()
             throws Exception

Description copied from class: Benchmark

Perform post-run cleanups.

Overrides:

cleanup in class Benchmark<RpcTaskResult>

Throws:

Exception

runLocal

public RpcTaskResult runLocal()
                       throws Exception

Description copied from class: Benchmark

Runs the test locally, in process.

Specified by:

runLocal in class Benchmark<RpcTaskResult>

Returns:

the task result

Throws:

Exception