T
- the type of task resultP
- the type of task parameterpublic abstract class StressMasterBenchBase<T extends MasterBenchTaskResultBase<P>,P extends MasterBenchBaseParameters> extends AbstractStressBench<T,P>
Modifier and Type | Class and Description |
---|---|
protected class |
StressMasterBenchBase.BenchContext |
Benchmark.MethodStatistics, Benchmark.ProfileInput
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 |
mParameters
mBaseParameters
Modifier | Constructor and Description |
---|---|
protected |
StressMasterBenchBase(P parameters)
Creates instance.
|
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 abstract Callable<Void> |
getBenchThread(StressMasterBenchBase.BenchContext context,
int index) |
protected abstract StressMasterBenchBase.BenchContext |
getContext() |
T |
runLocal()
Runs the test locally, in process.
|
run, validateParams
cleanup, generateJobConfig, getBenchDescription, mainInternal, parseParameters, prepare, processMethodProfiles, runSingleTask
protected byte[] mFiledata
protected org.apache.hadoop.fs.FileSystem[] mCachedFs
protected FileSystem[] mCachedNativeFs
protected final String mDirsDir
protected final String mFilesDir
protected final String mFixedDir
protected StressMasterBenchBase(P parameters)
protected abstract StressMasterBenchBase.BenchContext getContext() throws IOException, AlluxioException
IOException
AlluxioException
protected void deletePaths(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path basePath) throws Exception
Exception
public T runLocal() throws Exception
Benchmark
protected abstract Callable<Void> getBenchThread(StressMasterBenchBase.BenchContext context, int index)
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
IOException
AlluxioException
Copyright © 2023. All Rights Reserved.