public class IntegrationTestRegionReplicaReplication extends IntegrationTestIngest
Example usage:
hbase org.apache.hadoop.hbase.IntegrationTestRegionReplicaReplication -DIntegrationTestRegionReplicaReplication.num_keys_per_server=10000 -Dhbase.IntegrationTestRegionReplicaReplication.runtime=600000 -DIntegrationTestRegionReplicaReplication.read_delay_ms=5000 -DIntegrationTestRegionReplicaReplication.region_replication=3 -DIntegrationTestRegionReplicaReplication.region_replica_id=2 -DIntegrationTestRegionReplicaReplication.num_read_threads=100 -DIntegrationTestRegionReplicaReplication.num_write_threads=100
Modifier and Type | Class and Description |
---|---|
static class |
IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater
This extends MultiThreadedWriter to add a configurable delay to the keys written by the writer
threads to become available to the MultiThradedReader threads.
|
static class |
IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter
This extends MultiThreadedWriter to add a configurable delay to the keys written by the writer
threads to become available to the MultiThradedReader threads.
|
cluster, DEFAULT_NUM_KEYS_PER_SERVER, DEFAULT_NUM_READ_THREADS, DEFAULT_NUM_WRITE_THREADS, DEFAULT_RUN_TIME, HIPHEN, JUNIT_RUN_TIME, LOAD_TEST_TOOL_INIT_ARGS, loadTool, LOG, NUM_KEYS_PER_SERVER_KEY, NUM_READ_THREADS_KEY, NUM_WRITE_THREADS_KEY, RUN_TIME_KEY, util
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp
Constructor and Description |
---|
IntegrationTestRegionReplicaReplication() |
Modifier and Type | Method and Description |
---|---|
protected int |
getMinServerCount() |
static void |
main(java.lang.String[] args) |
protected void |
runIngestTest(long defaultRunTime,
long keysPerServerPerIter,
int colsPerKey,
int recordSize,
int writeThreads,
int readThreads) |
void |
setConf(Configuration conf) |
void |
testIngest() |
getArgsForLoadTestTool, getArgsForLoadTestToolInitTable, getColumnFamilies, getNumKeys, getTablename, initTable, internalRunIngestTest, runTestFromCommandLine, setUpCluster
addOptions, cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, processOptions, setUp, setUpMonkey, startMonkey
public IntegrationTestRegionReplicaReplication()
protected int getMinServerCount()
getMinServerCount
in class IntegrationTestIngest
public void setConf(Configuration conf)
public void testIngest() throws java.lang.Exception
testIngest
in class IntegrationTestIngest
java.lang.Exception
protected void runIngestTest(long defaultRunTime, long keysPerServerPerIter, int colsPerKey, int recordSize, int writeThreads, int readThreads) throws java.lang.Exception
runIngestTest
in class IntegrationTestIngest
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception