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:

StressClientIOBench, StressMasterBench, StressWorkerBench, 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
PlanConfig	generateJobConfig(String[] args) Generate a StressBenchConfig as the default JobConfig.
protected static void	mainInternal(String[] args, Benchmark benchmark)
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.

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

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

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

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