alluxio.stress.job

Class StressBenchConfig

java.lang.Object

alluxio.stress.job.StressBenchConfig

All Implemented Interfaces:

JobConfig, PlanConfig, Serializable

@ThreadSafe
public final class StressBenchConfig
extends Object
implements PlanConfig

Config for the stress test.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StressBenchConfig(String className, List<String> args, long startDelayMs, int clusterLimit)

Method Summary

Modifier and Type	Method and Description
Collection<String>	affectedPaths()
boolean	equals(Object obj)
List<String>	getArgs()
String	getClassName()
int	getClusterLimit()
String	getName()
long	getStartDelayMs()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StressBenchConfig

public StressBenchConfig(String className,
                         List<String> args,
                         long startDelayMs,
                         int clusterLimit)

Parameters:

className - the class name of the benchmark to run

args - the args for the benchmark

startDelayMs - the start delay for the distributed tasks, in ms

clusterLimit - the max number of workers to run on. If 0, run on entire cluster, If < 0, starts scheduling from the end of the worker list

Method Detail

getName

public String getName()

Specified by:

getName in interface JobConfig

Returns:

the name of the job

affectedPaths

public Collection<String> affectedPaths()

Specified by:

affectedPaths in interface JobConfig

Returns:

list of affected paths

getClassName

public String getClassName()

Returns:

the class name

getArgs

public List<String> getArgs()

Returns:

the list of arguments

getStartDelayMs

public long getStartDelayMs()

Returns:

the start delay in ms

getClusterLimit

public int getClusterLimit()

Returns:

the number of workers to run on. If < 0, starts from the end of the worker list If == 0, run on entire cluster

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object