public class TestReplicator extends TestReplicationBase
| Modifier and Type | Class and Description |
|---|---|
static class |
TestReplicator.FailureInjectingReplicationEndpointForTest |
static class |
TestReplicator.ReplicationEndpointForTest |
| 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, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, PEER_ID2, row, scopes, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2| 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) |
cleanUp, isSerialPeer, loadData, loadData, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, tearDownBase, waitForReplicationpublic static final HBaseClassTestRule CLASS_RULE
static final org.slf4j.Logger LOG
static final int NUM_ROWS
public TestReplicator()
public static void setUpBeforeClass() throws Exception
Exceptionpublic void testReplicatorBatching() throws Exception
Exceptionpublic void testReplicatorWithErrors() throws Exception
Exceptionpublic static void tearDownAfterClass() throws Exception
Exceptionprivate void truncateTable(HBaseTestingUtility util, org.apache.hadoop.hbase.TableName tablename) throws IOException
IOExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.