alluxio.stress.cli

Class StressMasterBenchBase<T extends MasterBenchTaskResultBase<P>,P extends MasterBenchBaseParameters>

java.lang.Object

alluxio.stress.cli.Benchmark<T>

alluxio.stress.cli.AbstractStressBench<T,P>

alluxio.stress.cli.StressMasterBenchBase<T,P>

Type Parameters:

T - the type of task result

P - the type of task parameter

Direct Known Subclasses:

MultiOperationStressMasterBench, StressMasterBench

public abstract class StressMasterBenchBase<T extends MasterBenchTaskResultBase<P>,P extends MasterBenchBaseParameters>
extends AbstractStressBench<T,P>

The base class for master stress bench tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	StressMasterBenchBase.BenchContext

Nested classes/interfaces inherited from class alluxio.stress.cli.Benchmark

Benchmark.MethodStatistics, Benchmark.ProfileInput

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.fs.FileSystem[]	mCachedFs Cached FS instances.
protected FileSystem[]	mCachedNativeFs In case the Alluxio Native API is used, use the following instead.
protected String	mDirsDir
protected byte[]	mFiledata
protected String	mFilesDir
protected String	mFixedDir
protected int[]	mPathRecord
protected int[]	mTreeLevelQuant
protected int	mTreeTotalCount

Fields inherited from class alluxio.stress.cli.AbstractStressBench

mParameters

Fields inherited from class alluxio.stress.cli.Benchmark

mBaseParameters

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StressMasterBenchBase(P parameters) Creates instance.

Method Summary

Modifier and Type	Method and Description
protected void	applyNativeOperation(FileSystem fs, Operation operation, long counter, org.apache.hadoop.fs.Path basePath, org.apache.hadoop.fs.Path fixedBasePath, int fixedCount)
protected void	deletePaths(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path basePath)
protected String	extractHostName(String mId)
protected abstract Callable<Void>	getBenchThread(StressMasterBenchBase.BenchContext context, int index)
protected abstract StressMasterBenchBase.BenchContext	getContext()
T	runLocal() Runs the test locally, in process.

Methods inherited from class alluxio.stress.cli.AbstractStressBench

run, validateParams

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

mFiledata

protected byte[] mFiledata

mCachedFs

protected org.apache.hadoop.fs.FileSystem[] mCachedFs

Cached FS instances.

mCachedNativeFs

protected FileSystem[] mCachedNativeFs

In case the Alluxio Native API is used, use the following instead.

mDirsDir

protected final String mDirsDir

See Also:

Constant Field Values

mFilesDir

protected final String mFilesDir

See Also:

Constant Field Values

mFixedDir

protected final String mFixedDir

See Also:

Constant Field Values

mPathRecord

protected int[] mPathRecord

mTreeLevelQuant

protected int[] mTreeLevelQuant

mTreeTotalCount

protected int mTreeTotalCount

Constructor Detail

StressMasterBenchBase

protected StressMasterBenchBase(P parameters)

Creates instance.

Method Detail

getContext

protected abstract StressMasterBenchBase.BenchContext getContext()
                                                          throws IOException,
                                                                 AlluxioException

Throws:

IOException

AlluxioException

deletePaths

protected void deletePaths(org.apache.hadoop.fs.FileSystem fs,
                           org.apache.hadoop.fs.Path basePath)
                    throws Exception

Throws:

Exception

runLocal

public T runLocal()
           throws Exception

Description copied from class: Benchmark

Runs the test locally, in process.

Specified by:

runLocal in class Benchmark<T extends MasterBenchTaskResultBase<P>>

Returns:

the task result

Throws:

Exception

getBenchThread

protected abstract Callable<Void> getBenchThread(StressMasterBenchBase.BenchContext context,
                                                 int index)

applyNativeOperation

protected void applyNativeOperation(FileSystem fs,
                                    Operation operation,
                                    long counter,
                                    org.apache.hadoop.fs.Path basePath,
                                    org.apache.hadoop.fs.Path fixedBasePath,
                                    int fixedCount)
                             throws IOException,
                                    AlluxioException

Throws:

IOException

AlluxioException

extractHostName

protected String extractHostName(String mId)