public class IntegrationTestReplication extends IntegrationTestBigLinkedList
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.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.
|
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 |
COLUMN_CLIENT, COLUMN_COUNT, COLUMN_PREV, DEFAULT_TABLE_NAME, FAMILY_NAME, NO_KEY, NUM_SLAVES_BASE, otherArgs, TABLE_NAME_KEY, toRun, util
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp
Constructor and Description |
---|
IntegrationTestReplication() |
Modifier and Type | Method and Description |
---|---|
protected void |
addOptions() |
static void |
main(java.lang.String[] args) |
protected void |
processOptions(CommandLine cmd) |
int |
runTestFromCommandLine() |
cleanUpCluster, getColumnFamilies, getTablename, setJobScannerConf, setUpCluster, testContinuousIngest
cleanUp, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, setUp, setUpMonkey, startMonkey
protected java.lang.String sourceClusterIdString
protected java.lang.String sinkClusterIdString
protected int numIterations
protected int numMappers
protected long numNodes
protected java.lang.String outputDir
protected int numReducers
protected int generateVerifyGap
protected java.lang.Integer width
protected java.lang.Integer wrapMultiplier
protected boolean noReplicationSetup
protected void addOptions()
addOptions
in class IntegrationTestBase
protected void processOptions(CommandLine cmd)
processOptions
in class IntegrationTestBigLinkedList
public int runTestFromCommandLine() throws java.lang.Exception
runTestFromCommandLine
in class IntegrationTestBigLinkedList
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception