org.apache.hadoop.hbase

Class IntegrationTestAcidGuarantees

java.lang.Object

org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.IntegrationTestBase

org.apache.hadoop.hbase.IntegrationTestAcidGuarantees

All Implemented Interfaces:

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

public class IntegrationTestAcidGuarantees
extends IntegrationTestBase

This Integration Test verifies acid guarantees across column families by frequently writing values to rows with multiple column families and concurrently reading entire rows that expect all column families.

Sample usage:

 hbase org.apache.hadoop.hbase.IntegrationTestAcidGuarantees -Dmillis=10000 -DnumWriters=50
 -DnumGetters=2 -DnumScanners=2 -DnumUniqueRows=5
 

Field Summary

Fields

Modifier and Type	Field and Description
private static int	SERVER_COUNT
(package private) AcidGuaranteesTestTool	tool

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

Method Summary

Modifier and Type	Method and Description
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)
private void	runTestAtomicity(long millisToRun, int numWriters, int numGetters, int numScanners, int numUniqueRows)
int	runTestFromCommandLine()
void	setUpCluster()
void	testGetAtomicity()
void	testMixedAtomicity()
void	testScanAtomicity()

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

addOptions, cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, loadMonkeyProperties, processBaseOptions, processOptions, setUp, setUpMonkey, 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

SERVER_COUNT

private static final int SERVER_COUNT

See Also:

Constant Field Values

tool

AcidGuaranteesTestTool tool

Constructor Detail

IntegrationTestAcidGuarantees

public IntegrationTestAcidGuarantees()

Method Detail

runTestFromCommandLine

public int runTestFromCommandLine()
                           throws Exception

Specified by:

runTestFromCommandLine in class IntegrationTestBase

Throws:

Exception

setUpCluster

public void setUpCluster()
                  throws Exception

Specified by:

setUpCluster 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.

runTestAtomicity

private void runTestAtomicity(long millisToRun,
                              int numWriters,
                              int numGetters,
                              int numScanners,
                              int numUniqueRows)
                       throws Exception

Throws:

Exception

testGetAtomicity

public void testGetAtomicity()
                      throws Exception

Throws:

Exception

testScanAtomicity

public void testScanAtomicity()
                       throws Exception

Throws:

Exception

testMixedAtomicity

public void testMixedAtomicity()
                        throws Exception

Throws:

Exception

main

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

Throws:

Exception