Package org.apache.hadoop.hbase

Class IntegrationTestRegionReplicaPerf

java.lang.Object

org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.IntegrationTestBase

org.apache.hadoop.hbase.IntegrationTestRegionReplicaPerf

All Implemented Interfaces:

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

@Tag("org.apache.hadoop.hbase.testclassification.IntegrationTests")
public class IntegrationTestRegionReplicaPerf
extends IntegrationTestBase

Test for comparing the performance impact of region replicas. Uses components of PerformanceEvaluation. Does not run from IntegrationTestsDriver because IntegrationTestBase is incompatible with the JUnit runner. Hence no @Test annotations either. See -help for full list of options.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	IntegrationTestRegionReplicaPerf.PerfEvalCallable	Wraps the invocation of PerformanceEvaluation in a Callable.
private static enum	IntegrationTestRegionReplicaPerf.Stat	Extract a descriptive statistic from a Histogram.
(package private) static class	IntegrationTestRegionReplicaPerf.TimingResult	Record the results from a single PerformanceEvaluation job run.

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 int	clusterSize
static final String	FAMILY_NAME
private static final org.slf4j.Logger	LOG
private static final String	NUM_RS_DEFAULT
private static final String	NUM_RS_KEY
private static final String	PRIMARY_TIMEOUT_DEFAULT
private static final String	PRIMARY_TIMEOUT_KEY
private int	primaryTimeout
private static final String	REPLICA_COUNT_DEFAULT
private static final String	REPLICA_COUNT_KEY
private int	replicaCount
private static final String	SLEEP_TIME_DEFAULT
private static final String	SLEEP_TIME_KEY
private long	sleepTime
private static final String	TABLE_NAME_DEFAULT
private static final String	TABLE_NAME_KEY
private org.apache.hadoop.hbase.TableName	tableName

Fields inherited from class org.apache.hadoop.hbase.IntegrationTestBase

CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp, util

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
IntegrationTestRegionReplicaPerf()

Method Summary

Modifier and Type	Method	Description
protected void	addOptions()
private static double	calcMean(String desc, IntegrationTestRegionReplicaPerf.Stat stat, List<IntegrationTestRegionReplicaPerf.TimingResult> results)	Compute the mean of the given stat from a timing results.
protected Set<String>	getColumnFamilies()	Provides the name of the CFs that are protected from random Chaos monkey activity (alter)
org.apache.hadoop.hbase.TableName	getTablename()	Provides the name of the table that is protected from random Chaos monkey activity
static void	main(String[] args)
protected void	processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)
int	runTestFromCommandLine()
void	setUp()
void	setUpCluster()
void	setUpMonkey()
void	test()

Methods inherited from class org.apache.hadoop.hbase.IntegrationTestBase

cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, loadMonkeyProperties, processBaseOptions, startMonkey

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

addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, 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

LOG

private static final org.slf4j.Logger LOG

SLEEP_TIME_KEY

private static final String SLEEP_TIME_KEY

See Also:

• Constant Field Values

SLEEP_TIME_DEFAULT

private static final String SLEEP_TIME_DEFAULT

See Also:

• Constant Field Values

TABLE_NAME_KEY

private static final String TABLE_NAME_KEY

See Also:

• Constant Field Values

TABLE_NAME_DEFAULT

private static final String TABLE_NAME_DEFAULT

See Also:

• Constant Field Values

REPLICA_COUNT_KEY

private static final String REPLICA_COUNT_KEY

See Also:

• Constant Field Values

REPLICA_COUNT_DEFAULT

private static final String REPLICA_COUNT_DEFAULT

See Also:

• Constant Field Values

PRIMARY_TIMEOUT_KEY

private static final String PRIMARY_TIMEOUT_KEY

See Also:

• Constant Field Values

PRIMARY_TIMEOUT_DEFAULT

private static final String PRIMARY_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

NUM_RS_KEY

private static final String NUM_RS_KEY

See Also:

• Constant Field Values

NUM_RS_DEFAULT

private static final String NUM_RS_DEFAULT

See Also:

• Constant Field Values

FAMILY_NAME

public static final String FAMILY_NAME

See Also:

• Constant Field Values

tableName

private org.apache.hadoop.hbase.TableName tableName

sleepTime

private long sleepTime

replicaCount

private int replicaCount

primaryTimeout

private int primaryTimeout

clusterSize

private int clusterSize

Constructor Details

IntegrationTestRegionReplicaPerf

public IntegrationTestRegionReplicaPerf()

Method Details

setUp

public void setUp()
           throws Exception

Overrides:

setUp in class IntegrationTestBase

Throws:

Exception

setUpCluster

public void setUpCluster()
                  throws Exception

Specified by:

setUpCluster in class IntegrationTestBase

Throws:

Exception

setUpMonkey

public void setUpMonkey()
                 throws Exception

Overrides:

setUpMonkey in class IntegrationTestBase

Throws:

Exception

addOptions

protected void addOptions()

Overrides:

addOptions in class IntegrationTestBase

processOptions

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

Overrides:

processOptions in class IntegrationTestBase

runTestFromCommandLine

public int runTestFromCommandLine()
                           throws Exception

Specified by:

runTestFromCommandLine in class IntegrationTestBase

Throws:

Exception

getTablename

public org.apache.hadoop.hbase.TableName getTablename()

Description copied from class: IntegrationTestBase

Provides the name of the table that is protected from random Chaos monkey activity

Specified by:

getTablename in class IntegrationTestBase

Returns:

table to not delete.

getColumnFamilies

protected Set<String> getColumnFamilies()

Description copied from class: IntegrationTestBase

Provides the name of the CFs that are protected from random Chaos monkey activity (alter)

Specified by:

getColumnFamilies in class IntegrationTestBase

Returns:

set of cf names to protect.

calcMean

private static double calcMean(String desc,
 IntegrationTestRegionReplicaPerf.Stat stat,
 List<IntegrationTestRegionReplicaPerf.TimingResult> results)

Compute the mean of the given stat from a timing results.

test

public void test()
          throws Exception

Throws:

Exception

main

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

Throws:

Exception