alluxio.stress.cli

Class Benchmark<T extends TaskResult>

java.lang.Object

alluxio.stress.cli.Benchmark<T>

Type Parameters:

T - the type of task result

Direct Known Subclasses:

AbstractMaxThroughput, AbstractStressBench, CompactionBench, FuseIOBench, RpcBench, StressJobServiceBench, UfsIOBench

public abstract class Benchmark<T extends TaskResult>
extends Object

Base class for all stress benchmarks.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	Benchmark.MethodStatistics
protected static class	Benchmark.ProfileInput

Field Summary

Fields

Modifier and Type	Field and Description
protected BaseParameters	mBaseParameters

Constructor Summary

Constructors

Constructor and Description
Benchmark()

Method Summary

Modifier and Type	Method and Description
void	cleanup() Perform post-run cleanups.
PlanConfig	generateJobConfig(String[] args) Generate a StressBenchConfig as the default JobConfig.
abstract String	getBenchDescription() Get the description of the bench.
protected static void	mainInternal(String[] args, Benchmark benchmark)
protected void	parseParameters(String[] args)
abstract void	prepare() Prepares to run the test.
protected Map<String,Benchmark.MethodStatistics>	processMethodProfiles(long startMs, long endMs, java.util.function.Function<Benchmark.ProfileInput,String> nameTransformer)
String	run(String[] args) Runs the test and returns the string output.
abstract T	runLocal() Runs the test locally, in process.
protected String	runSingleTask(String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

mBaseParameters

protected BaseParameters mBaseParameters

Constructor Detail

Benchmark

public Benchmark()

Method Detail

getBenchDescription

public abstract String getBenchDescription()

Get the description of the bench.

Returns:

string of the bench description

runLocal

public abstract T runLocal()
                    throws Exception

Runs the test locally, in process.

Returns:

the task result

Throws:

Exception

prepare

public abstract void prepare()
                      throws Exception

Prepares to run the test.

Throws:

Exception

cleanup

public void cleanup()
             throws Exception

Perform post-run cleanups.

Throws:

Exception

mainInternal

protected static void mainInternal(String[] args,
                                   Benchmark benchmark)

generateJobConfig

public PlanConfig generateJobConfig(String[] args)

Generate a StressBenchConfig as the default JobConfig.

Parameters:

args - arguments

Returns:

the JobConfig

run

public String run(String[] args)
           throws Exception

Runs the test and returns the string output.

Parameters:

args - the command-line args

Returns:

the string result output

Throws:

Exception

parseParameters

protected void parseParameters(String[] args)

runSingleTask

protected String runSingleTask(String[] args)
                        throws Exception

Throws:

Exception

processMethodProfiles

protected Map<String,Benchmark.MethodStatistics> processMethodProfiles(long startMs,
                                                                       long endMs,
                                                                       java.util.function.Function<Benchmark.ProfileInput,String> nameTransformer)
                                                                throws IOException

Parameters:

startMs - the start time

endMs - the end time

nameTransformer - function which transforms the type and method into a name. If the function returns null, then the method is skipped

Returns:

a map of names to statistics

Throws:

IOException