public class TestReplicator extends TestReplicationBase
Modifier and Type | Class and Description |
---|---|
static class |
TestReplicator.FailureInjectingReplicationEndpointForTest |
static class |
TestReplicator.ReplicationEndpointForTest |
TestReplicationBase.ReplicationEndpointTest
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
(package private) static org.slf4j.Logger |
LOG |
(package private) static int |
NUM_ROWS |
admin, CONF_WITH_LOCALFS, CONF1, CONF2, connection1, connection2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, replicateCount, replicatedEntries, row, SLEEP_TIME, tableName, UTIL1, UTIL2
Constructor and Description |
---|
TestReplicator() |
Modifier and Type | Method and Description |
---|---|
static void |
setUpBeforeClass() |
static void |
tearDownAfterClass() |
void |
testReplicatorBatching() |
void |
testReplicatorWithErrors() |
private void |
truncateTable(HBaseTestingUtility util,
org.apache.hadoop.hbase.TableName tablename) |
addPeer, cleanUp, createTable, isSerialPeer, loadData, loadData, removePeer, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, tearDownBase, waitForReplication, waitForReplication
public static final HBaseClassTestRule CLASS_RULE
static final org.slf4j.Logger LOG
static final int NUM_ROWS
public TestReplicator()
public static void setUpBeforeClass() throws Exception
Exception
public void testReplicatorBatching() throws Exception
Exception
public void testReplicatorWithErrors() throws Exception
Exception
public static void tearDownAfterClass() throws Exception
Exception
private void truncateTable(HBaseTestingUtility util, org.apache.hadoop.hbase.TableName tablename) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.