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, PEER_ID2, row, scopes, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2| 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, isSerialPeer, loadData, loadData, runSimplePutDeleteTest, runSmallBatchTest, setUpBeforeClass, tearDownAfterClass, tearDownBase, waitForReplicationpublic 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 TestReplicationBaseExceptionpublic void testEditsStuckBehindDroppedTable() throws Exception
Exceptionpublic void testEditsDroppedWithDroppedTable() throws Exception
Exceptionpublic void testEditsDroppedWithDroppedTableNS() throws Exception
Exceptionprivate byte[] generateRowKey(int id)
private void testEditsBehindDroppedTable(boolean allowProceeding, String tName) throws Exception
Exceptionpublic void testEditsBehindDroppedTableTiming() throws Exception
Exceptionprivate boolean peerHasAllNormalRows() throws IOException
IOExceptionprivate void verifyReplicationProceeded() throws Exception
Exceptionprivate void verifyReplicationStuck() throws Exception
ExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.