public class TestReplicationSyncUpTool extends TestReplicationBase
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
protected static byte[] |
famName |
protected org.apache.hadoop.hbase.client.Table |
ht1Source |
protected org.apache.hadoop.hbase.client.Table |
ht1TargetAtPeer1 |
protected org.apache.hadoop.hbase.client.Table |
ht2Source |
protected org.apache.hadoop.hbase.client.Table |
ht2TargetAtPeer1 |
private static org.slf4j.Logger |
LOG |
protected static byte[] |
noRepfamName |
private static byte[] |
qualName |
private static org.apache.hadoop.hbase.TableName |
t1_su |
private org.apache.hadoop.hbase.HTableDescriptor |
t1_syncupSource |
private org.apache.hadoop.hbase.HTableDescriptor |
t1_syncupTarget |
private static org.apache.hadoop.hbase.TableName |
t2_su |
private org.apache.hadoop.hbase.HTableDescriptor |
t2_syncupSource |
private org.apache.hadoop.hbase.HTableDescriptor |
t2_syncupTarget |
admin, CONF_WITH_LOCALFS, conf1, conf2, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, PEER_ID2, row, scopes, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2
Constructor and Description |
---|
TestReplicationSyncUpTool() |
Modifier and Type | Method and Description |
---|---|
private void |
mimicSyncUpAfterDelete() |
private void |
mimicSyncUpAfterPut() |
private void |
putAndReplicateRows() |
void |
setUp() |
protected void |
setupReplication() |
protected void |
syncUp(HBaseTestingUtility ut) |
void |
tearDownBase() |
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.
|
cleanUp, isSerialPeer, loadData, loadData, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, tearDownAfterClass, waitForReplication
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final org.apache.hadoop.hbase.TableName t1_su
private static final org.apache.hadoop.hbase.TableName t2_su
protected static final byte[] famName
private static final byte[] qualName
protected static final byte[] noRepfamName
private org.apache.hadoop.hbase.HTableDescriptor t1_syncupSource
private org.apache.hadoop.hbase.HTableDescriptor t1_syncupTarget
private org.apache.hadoop.hbase.HTableDescriptor t2_syncupSource
private org.apache.hadoop.hbase.HTableDescriptor t2_syncupTarget
protected org.apache.hadoop.hbase.client.Table ht1Source
protected org.apache.hadoop.hbase.client.Table ht2Source
protected org.apache.hadoop.hbase.client.Table ht1TargetAtPeer1
protected org.apache.hadoop.hbase.client.Table ht2TargetAtPeer1
public TestReplicationSyncUpTool()
public void tearDownBase() throws Exception
tearDownBase
in class TestReplicationBase
Exception
public void testSyncUpTool() throws Exception
Exception
protected void setupReplication() throws Exception
Exception
private void putAndReplicateRows() throws Exception
Exception
private void mimicSyncUpAfterDelete() throws Exception
Exception
private void mimicSyncUpAfterPut() throws Exception
Exception
protected void syncUp(HBaseTestingUtility ut) throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.