alluxio.stress.cli.suite

Class AbstractMaxThroughput<Q extends TaskResult,T extends AbstractMaxThroughputSummary<P,S>,S extends GeneralBenchSummary<Q>,P extends Parameters>

java.lang.Object

alluxio.stress.cli.Benchmark<T>

alluxio.stress.cli.suite.AbstractMaxThroughput<Q,T,S,P>

Type Parameters:

T - the MaxThroughput bench result summary

S - the general Bench Summary with common method

P - the stress bench parameter

Q - the single task result

Direct Known Subclasses:

JobServiceMaxThroughput, MasterMaxThroughput

public abstract class AbstractMaxThroughput<Q extends TaskResult,T extends AbstractMaxThroughputSummary<P,S>,S extends GeneralBenchSummary<Q>,P extends Parameters>
extends Benchmark<T>

abstract class for MaxThroughput benchmark.

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 static org.slf4j.Logger	LOG
protected int	mInitialThroughput
protected T	mMaxThroughputResult
protected P	mParameters

Fields inherited from class alluxio.stress.cli.Benchmark

mBaseParameters

Constructor Summary

Constructors

Constructor and Description
AbstractMaxThroughput()

Method Summary

Modifier and Type	Method and Description
abstract void	initParameters(List<String> baseArgs) Construct parameters with user command-line args.
String	run(String[] args) Runs the test and returns the string output.
T	runLocal() Runs the test locally, in process.
protected abstract S	runSingleTest(List<String> args, int targetThroughput) Unit test for max throughput.
protected void	updateArgValue(List<String> args, String argName, String argValue)

Methods inherited from class alluxio.stress.cli.Benchmark

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

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

mParameters

protected P extends Parameters mParameters

mMaxThroughputResult

protected T extends AbstractMaxThroughputSummary<P,S> mMaxThroughputResult

mInitialThroughput

protected int mInitialThroughput

Constructor Detail

AbstractMaxThroughput

public AbstractMaxThroughput()

Method Detail

initParameters

public abstract void initParameters(List<String> baseArgs)

Construct parameters with user command-line args.

Parameters:

baseArgs - initial args passed by the user

runSingleTest

protected abstract S runSingleTest(List<String> args,
                                   int targetThroughput)
                            throws Exception

Unit test for max throughput.

Returns:

the results

Throws:

Exception

run

public String run(String[] args)
           throws Exception

Runs the test and returns the string output.

Overrides:

run in class Benchmark<T extends AbstractMaxThroughputSummary<P,S>>

Parameters:

args - the command-line args

Returns:

the string result output

Throws:

Exception

updateArgValue

protected void updateArgValue(List<String> args,
                              String argName,
                              String argValue)

runLocal

public T runLocal()

Description copied from class: Benchmark

Runs the test locally, in process.

Specified by:

runLocal in class Benchmark<T extends AbstractMaxThroughputSummary<P,S>>

Returns:

the task result