public class TestMigrateReplicationQueue extends TestReplicationBase
TestReplicationBase.ReplicationEndpointTest
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
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 |
---|
TestMigrateReplicationQueue() |
Modifier and Type | Method and Description |
---|---|
private int |
disableAndInsert() |
private String |
getQueuesZNode() |
private void |
mockData() |
void |
testMigrate() |
addPeer, cleanUp, createTable, isSerialPeer, isSyncPeer, loadData, loadData, removePeer, restartSourceCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication
public static final HBaseClassTestRule CLASS_RULE
public TestMigrateReplicationQueue()
private int disableAndInsert() throws Exception
Exception
private String getQueuesZNode() throws IOException
IOException
public void testMigrate() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.