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

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 and Description
(package private) static class	IntegrationTestRegionReplicaPerf.PerfEvalCallable Wraps the invocation of PerformanceEvaluation in a Callable.
private static class	IntegrationTestRegionReplicaPerf.Stat Extract a descriptive statistic from a Histogram.
(package private) static class	IntegrationTestRegionReplicaPerf.TimingResult Record the results from a single PerformanceEvaluation job run.

Field Summary

Fields

Modifier and Type	Field and Description
private int	clusterSize
static String	FAMILY_NAME
private static org.slf4j.Logger	LOG
private static String	NUM_RS_DEFAULT
private static String	NUM_RS_KEY
private static String	PRIMARY_TIMEOUT_DEFAULT
private static String	PRIMARY_TIMEOUT_KEY
private int	primaryTimeout
private static String	REPLICA_COUNT_DEFAULT
private static String	REPLICA_COUNT_KEY
private int	replicaCount
private static String	SLEEP_TIME_DEFAULT
private static String	SLEEP_TIME_KEY
private long	sleepTime
private static String	TABLE_NAME_DEFAULT
private static 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 and Description
IntegrationTestRegionReplicaPerf()

Method Summary

Modifier and Type	Method and 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, 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 Detail

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 Detail

IntegrationTestRegionReplicaPerf

public IntegrationTestRegionReplicaPerf()

Method Detail

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