public class TestReplicationDroppedTables extends TestReplicationBase
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
private static int |
ROWS_COUNT |
admin, CONF_WITH_LOCALFS, CONF1, CONF2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, row, SLEEP_TIME, tableName, UTIL1, UTIL2
Constructor and Description |
---|
TestReplicationDroppedTables() |
Modifier and Type | Method and Description |
---|---|
private byte[] |
generateRowKey(int id) |
private boolean |
peerHasAllNormalRows() |
void |
setUpBase() |
private void |
testEditsBehindDroppedTable(boolean allowProceeding,
String tName) |
void |
testEditsBehindDroppedTableTiming() |
void |
testEditsDroppedWithDroppedTable() |
void |
testEditsDroppedWithDroppedTableNS() |
void |
testEditsStuckBehindDroppedTable() |
private void |
verifyReplicationProceeded() |
private void |
verifyReplicationStuck() |
cleanUp, configureClusters, isSerialPeer, loadData, loadData, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBeforeClass, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final int ROWS_COUNT
public TestReplicationDroppedTables()
public void setUpBase() throws Exception
setUpBase
in class TestReplicationBase
Exception
public void testEditsStuckBehindDroppedTable() throws Exception
Exception
public void testEditsDroppedWithDroppedTable() throws Exception
Exception
public void testEditsDroppedWithDroppedTableNS() throws Exception
Exception
private byte[] generateRowKey(int id)
private void testEditsBehindDroppedTable(boolean allowProceeding, String tName) throws Exception
Exception
public void testEditsBehindDroppedTableTiming() throws Exception
Exception
private boolean peerHasAllNormalRows() throws IOException
IOException
private void verifyReplicationProceeded() throws Exception
Exception
private void verifyReplicationStuck() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.