alluxio.job.plan.stress

Class StressBenchDefinition

java.lang.Object

alluxio.job.plan.stress.StressBenchDefinition

All Implemented Interfaces:

PlanDefinition<StressBenchConfig,ArrayList<String>,String>

public final class StressBenchDefinition
extends Object
implements PlanDefinition<StressBenchConfig,ArrayList<String>,String>

The definition for the stress bench job, which runs distributed benchmarks. StressBenchConfig is the configuration class, each task takes a List as a list of command-line arguments to the benchmark command, and each task returns the string output.

Constructor Summary

Constructors

Constructor and Description
StressBenchDefinition() Constructs a new instance.

Method Summary

Modifier and Type	Method and Description
Class<StressBenchConfig>	getJobConfigClass()
String	join(StressBenchConfig config, Map<WorkerInfo,String> taskResults) Joins the task results on the master.
String	runTask(StressBenchConfig config, ArrayList<String> args, RunTaskContext runTaskContext) Runs the task in the executor.
Set<Pair<WorkerInfo,ArrayList<String>>>	selectExecutors(StressBenchConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context) Selects the workers to run the task.

Methods inherited from class java.lang.Object

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

Constructor Detail

StressBenchDefinition

public StressBenchDefinition()

Constructs a new instance.

Method Detail

getJobConfigClass

public Class<StressBenchConfig> getJobConfigClass()

Specified by:

getJobConfigClass in interface PlanDefinition<StressBenchConfig,ArrayList<String>,String>

Returns:

the class of the associated JobConfig

selectExecutors

public Set<Pair<WorkerInfo,ArrayList<String>>> selectExecutors(StressBenchConfig config,
                                                               List<WorkerInfo> jobWorkerInfoList,
                                                               SelectExecutorsContext context)
                                                        throws Exception

Description copied from interface: PlanDefinition

Selects the workers to run the task.

Specified by:

selectExecutors in interface PlanDefinition<StressBenchConfig,ArrayList<String>,String>

Parameters:

config - the job configuration

jobWorkerInfoList - the list of available workers' information

context - the context containing information used to select executors

Returns:

a set of pairs of selected workers to the parameters to pass along

Throws:

Exception - if any error occurs

runTask

public String runTask(StressBenchConfig config,
                      ArrayList<String> args,
                      RunTaskContext runTaskContext)
               throws Exception

Description copied from interface: PlanDefinition

Runs the task in the executor.

Specified by:

runTask in interface PlanDefinition<StressBenchConfig,ArrayList<String>,String>

Parameters:

config - the job configuration

args - the arguments passed in

runTaskContext - the context containing information used to execute a task

Returns:

the task result

Throws:

Exception - if any error occurs

join

public String join(StressBenchConfig config,
                   Map<WorkerInfo,String> taskResults)
            throws Exception

Description copied from interface: PlanDefinition

Joins the task results on the master.

Specified by:

join in interface PlanDefinition<StressBenchConfig,ArrayList<String>,String>

Parameters:

config - the job configuration

taskResults - the task results

Returns:

the joined results

Throws:

Exception - if any error occurs