alluxio.stress.cli.client

Class CompactionBench

java.lang.Object

alluxio.stress.cli.Benchmark<CompactionTaskResult>

alluxio.stress.cli.client.CompactionBench

public class CompactionBench
extends Benchmark<CompactionTaskResult>

Benchmark that simulates a workload that compacts many small files into a bigger file.

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 FileSystem[]	mCachedFs
protected CompactionParameters	mParameters
protected ExecutorService	mPool

Fields inherited from class alluxio.stress.cli.Benchmark

mBaseParameters

Constructor Summary

Constructors

Constructor and Description
CompactionBench()

Method Summary

Modifier and Type	Method and Description
void	cleanup() Perform post-run cleanups.
String	getBenchDescription() Get the description of the bench.
ExecutorService	getPool() If the thread pool is not yet initialized, creates the pool.
static void	main(String[] args)
void	prepare() Prepares to run the test.
CompactionTaskResult	runLocal() Runs the test locally, in process.

Methods inherited from class alluxio.stress.cli.Benchmark

generateJobConfig, mainInternal, parseParameters, processMethodProfiles, run, runSingleTask

Methods inherited from class java.lang.Object

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

Field Detail

mPool

protected ExecutorService mPool

mParameters

protected final CompactionParameters mParameters

mCachedFs

protected FileSystem[] mCachedFs

Constructor Detail

CompactionBench

public CompactionBench()

Method Detail

main

public static void main(String[] args)

Parameters:

args - command-line arguments

getBenchDescription

public String getBenchDescription()

Description copied from class: Benchmark

Get the description of the bench.

Specified by:

getBenchDescription in class Benchmark<CompactionTaskResult>

Returns:

string of the bench description

runLocal

public CompactionTaskResult runLocal()
                              throws Exception

Description copied from class: Benchmark

Runs the test locally, in process.

Specified by:

runLocal in class Benchmark<CompactionTaskResult>

Returns:

the task result

Throws:

Exception

prepare

public void prepare()
             throws Exception

Description copied from class: Benchmark

Prepares to run the test.

Specified by:

prepare in class Benchmark<CompactionTaskResult>

Throws:

Exception

cleanup

public void cleanup()
             throws Exception

Description copied from class: Benchmark

Perform post-run cleanups.

Overrides:

cleanup in class Benchmark<CompactionTaskResult>

Throws:

Exception

getPool

public ExecutorService getPool()

If the thread pool is not yet initialized, creates the pool.

Returns:

the thread pool