public class ReplicationDroppedTablesTestBase extends TestReplicationBase
TestReplicationBase.ReplicationEndpointTest
Modifier and Type | Field and Description |
---|---|
private static boolean |
ALLOW_PROCEEDING |
private static org.slf4j.Logger |
LOG |
protected static int |
ROWS_COUNT |
protected static byte[] |
VALUE |
CONF_WITH_LOCALFS, CONF1, CONF2, connection1, connection2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, replicateCount, replicatedEntries, row, SLEEP_TIME, tableName, UTIL1, UTIL2
Constructor and Description |
---|
ReplicationDroppedTablesTestBase() |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
generateRowKey(int id) |
private boolean |
peerHasAllNormalRows() |
protected static void |
setupClusters(boolean allowProceeding) |
protected void |
testEditsBehindDroppedTable(String tName) |
protected void |
verifyReplicationProceeded() |
protected void |
verifyReplicationStuck() |
addPeer, cleanUp, configureClusters, createTable, isSerialPeer, isSyncPeer, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication
private static final org.slf4j.Logger LOG
protected static final int ROWS_COUNT
protected static byte[] VALUE
private static boolean ALLOW_PROCEEDING
public ReplicationDroppedTablesTestBase()
protected static void setupClusters(boolean allowProceeding) throws Exception
Exception
protected final byte[] generateRowKey(int id)
protected final void testEditsBehindDroppedTable(String tName) throws Exception
Exception
private boolean peerHasAllNormalRows() throws IOException
IOException
protected final void verifyReplicationProceeded() throws Exception
Exception
protected final void verifyReplicationStuck() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.