Package org.apache.hadoop.hbase.master.procedure

Class MasterProcedureSchedulerPerformanceEvaluation

java.lang.Object

org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.master.procedure.MasterProcedureSchedulerPerformanceEvaluation

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class MasterProcedureSchedulerPerformanceEvaluation
extends org.apache.hadoop.hbase.util.AbstractHBaseTool

Tool to test performance of locks and queues in procedure scheduler independently from other framework components. Inserts table and region operations in the scheduler, then polls them and exercises their locks Number of tables, regions and operations can be set using cli args.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	MasterProcedureSchedulerPerformanceEvaluation.AddProcsWorker
private class	MasterProcedureSchedulerPerformanceEvaluation.PollAndLockWorker
private static interface	MasterProcedureSchedulerPerformanceEvaluation.ProcedureFactory
private class	MasterProcedureSchedulerPerformanceEvaluation.RegionProcedure
private class	MasterProcedureSchedulerPerformanceEvaluation.RegionProcedureFactory
private class	MasterProcedureSchedulerPerformanceEvaluation.TableProcedure
private class	MasterProcedureSchedulerPerformanceEvaluation.TableProcedureFactory

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.util.AbstractHBaseTool.OptionsOrderComparator

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicLong	completed
static final int	DEFAULT_NUM_OPERATIONS
static final int	DEFAULT_NUM_TABLES
static final int	DEFAULT_NUM_THREADS
static final String	DEFAULT_OPS_TYPE
static final int	DEFAULT_REGIONS_PER_TABLE
static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option	NUM_OPERATIONS_OPTION
static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option	NUM_TABLES_OPTION
static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option	NUM_THREADS_OPTION
private int	numOps
private int	numTables
private int	numThreads
(package private) MasterProcedureSchedulerPerformanceEvaluation.ProcedureFactory[]	ops
static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option	OPS_TYPE_OPTION
private String	opsType
private org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler	procedureScheduler
private final AtomicLong	procIds	WORKERS
static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option	REGIONS_PER_TABLE_OPTION
private int	regionsPerTable
protected static final HBaseTestingUtility	UTIL
private final AtomicLong	yield

Fields inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS, LONG_HELP_OPTION, options, SHORT_HELP_OPTION

Constructor Summary

Constructors

Constructor	Description
MasterProcedureSchedulerPerformanceEvaluation()

Method Summary

Modifier and Type	Method	Description
protected void	addOptions()
protected int	doWork()
static void	main(String[] args)
protected void	processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)
(package private) long	runThreads(Thread[] threads)	Starts the threads and waits for them to finish.
private void	setupOperations()

Methods inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, getConf, getOptionAsDouble, getOptionAsInt, getOptionAsInt, getOptionAsLong, getOptionAsLong, newParser, parseArgs, parseInt, parseLong, printUsage, printUsage, processOldArgs, run, setConf

Methods inherited from class java.lang.Object

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

Field Details

UTIL

protected static final HBaseTestingUtility UTIL

DEFAULT_NUM_TABLES

public static final int DEFAULT_NUM_TABLES

See Also:

• Constant Field Values

NUM_TABLES_OPTION

public static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_TABLES_OPTION

DEFAULT_REGIONS_PER_TABLE

public static final int DEFAULT_REGIONS_PER_TABLE

See Also:

• Constant Field Values

REGIONS_PER_TABLE_OPTION

public static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option REGIONS_PER_TABLE_OPTION

DEFAULT_NUM_OPERATIONS

public static final int DEFAULT_NUM_OPERATIONS

See Also:

• Constant Field Values

NUM_OPERATIONS_OPTION

public static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_OPERATIONS_OPTION

DEFAULT_NUM_THREADS

public static final int DEFAULT_NUM_THREADS

See Also:

• Constant Field Values

NUM_THREADS_OPTION

public static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option NUM_THREADS_OPTION

DEFAULT_OPS_TYPE

public static final String DEFAULT_OPS_TYPE

See Also:

• Constant Field Values

OPS_TYPE_OPTION

public static final org.apache.hbase.thirdparty.org.apache.commons.cli.Option OPS_TYPE_OPTION

numTables

private int numTables

regionsPerTable

private int regionsPerTable

numOps

private int numOps

numThreads

private int numThreads

opsType

private String opsType

procedureScheduler

private org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler procedureScheduler

ops

MasterProcedureSchedulerPerformanceEvaluation.ProcedureFactory[] ops

procIds

private final AtomicLong procIds

WORKERS

yield

private final AtomicLong yield

completed

private final AtomicLong completed

Constructor Details

MasterProcedureSchedulerPerformanceEvaluation

public MasterProcedureSchedulerPerformanceEvaluation()

Method Details

setupOperations

private void setupOperations()
                      throws Exception

Throws:

Exception

addOptions

protected void addOptions()

Specified by:

addOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

processOptions

protected void processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)

Specified by:

processOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

runThreads

long runThreads(Thread[] threads)
         throws Exception

Starts the threads and waits for them to finish.

Returns:

time taken by threads to complete, in milliseconds.

Throws:

Exception

doWork

protected int doWork()
              throws Exception

Specified by:

doWork in class org.apache.hadoop.hbase.util.AbstractHBaseTool

Throws:

Exception

main

public static void main(String[] args)
                 throws IOException

Throws:

IOException