public class TestReplicationSyncUpTool extends TestReplicationBase
Modifier and Type | Field and Description |
---|---|
protected static byte[] |
famName |
protected Table |
ht1Source |
protected Table |
ht1TargetAtPeer1 |
protected Table |
ht2Source |
protected Table |
ht2TargetAtPeer1 |
protected static byte[] |
noRepfamName |
admin, CONF_WITH_LOCALFS, conf1, conf2, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, row, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2
Constructor and Description |
---|
TestReplicationSyncUpTool() |
Modifier and Type | Method and Description |
---|---|
void |
setUp() |
protected void |
setupReplication() |
protected void |
syncUp(HBaseTestingUtility ut) |
void |
testSyncUpTool()
Add a row to a table in each cluster, check it's replicated, delete it,
check's gone Also check the puts and deletes are not replicated back to
the originating cluster.
|
setUpBeforeClass, tearDownAfterClass
protected static final byte[] famName
protected static final byte[] noRepfamName
protected Table ht1Source
protected Table ht2Source
protected Table ht1TargetAtPeer1
protected Table ht2TargetAtPeer1
public void setUp() throws java.lang.Exception
java.lang.Exception
public void testSyncUpTool() throws java.lang.Exception
java.lang.Exception
protected void setupReplication() throws java.lang.Exception
java.lang.Exception
protected void syncUp(HBaseTestingUtility ut) throws java.lang.Exception
java.lang.Exception