org.apache.hadoop.hbase.test

Class IntegrationTestReplication

java.lang.Object

org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.IntegrationTestBase

org.apache.hadoop.hbase.test.IntegrationTestBigLinkedList

org.apache.hadoop.hbase.test.IntegrationTestReplication

public class IntegrationTestReplication
extends IntegrationTestBigLinkedList

This is an integration test for replication. It is derived off IntegrationTestBigLinkedList that creates a large circular linked list in one cluster and verifies that the data is correct in a sink cluster. The test handles creating the tables and schema and setting up the replication.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	IntegrationTestReplication.ClusterID Wrapper around an HBase ClusterID allowing us to get admin connections and configurations for it
protected class	IntegrationTestReplication.VerifyReplicationLoop The main runner loop for the test.

Field Summary

Fields

Modifier and Type	Field and Description
protected int	generateVerifyGap
protected boolean	noReplicationSetup
protected int	numIterations
protected int	numMappers
protected long	numNodes
protected int	numReducers
protected java.lang.String	outputDir
protected java.lang.String	sinkClusterIdString
protected java.lang.String	sourceClusterIdString
protected java.lang.Integer	width
protected java.lang.Integer	wrapMultiplier

Fields inherited from class org.apache.hadoop.hbase.test.IntegrationTestBigLinkedList

COLUMN_CLIENT, COLUMN_COUNT, COLUMN_PREV, DEFAULT_TABLE_NAME, FAMILY_NAME, NO_KEY, NUM_SLAVES_BASE, otherArgs, TABLE_NAME_KEY, toRun, util

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

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

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

cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS

Constructor Summary

Constructors

Constructor and Description
IntegrationTestReplication()

Method Summary

Modifier and Type	Method and Description
protected void	addOptions() Override this to add command-line options using AbstractHBaseTool.addOptWithArg(java.lang.String, java.lang.String) and similar methods.
static void	main(java.lang.String[] args)
protected void	processOptions(CommandLine cmd) This method is called to process the options after they have been parsed.
int	runTestFromCommandLine()

Methods inherited from class org.apache.hadoop.hbase.test.IntegrationTestBigLinkedList

cleanUpCluster, getColumnFamilies, getTablename, setJobScannerConf, setUpCluster, testContinuousIngest

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

cleanUp, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, setUp, setUpMonkey, startMonkey

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

addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, parseArgs, parseInt, parseLong, printUsage, printUsage, run, setConf

Methods inherited from class java.lang.Object

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

Field Detail

sourceClusterIdString

protected java.lang.String sourceClusterIdString

sinkClusterIdString

protected java.lang.String sinkClusterIdString

numIterations

protected int numIterations

numMappers

protected int numMappers

numNodes

protected long numNodes

outputDir

protected java.lang.String outputDir

numReducers

protected int numReducers

generateVerifyGap

protected int generateVerifyGap

width

protected java.lang.Integer width

wrapMultiplier

protected java.lang.Integer wrapMultiplier

noReplicationSetup

protected boolean noReplicationSetup

Constructor Detail

IntegrationTestReplication

public IntegrationTestReplication()

Method Detail

addOptions

protected void addOptions()

Description copied from class: AbstractHBaseTool

Override this to add command-line options using AbstractHBaseTool.addOptWithArg(java.lang.String, java.lang.String) and similar methods.

Overrides:

addOptions in class IntegrationTestBase

processOptions

protected void processOptions(CommandLine cmd)

Description copied from class: AbstractHBaseTool

This method is called to process the options after they have been parsed.

Overrides:

processOptions in class IntegrationTestBigLinkedList

runTestFromCommandLine

public int runTestFromCommandLine()
                           throws java.lang.Exception

Overrides:

runTestFromCommandLine in class IntegrationTestBigLinkedList

Throws:

java.lang.Exception

main

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

Throws:

java.lang.Exception