Package org.apache.hadoop.hbase.master.replication

Class TestMigrateReplicationQueue

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.master.replication.TestMigrateReplicationQueue

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestMigrateReplicationQueue
extends TestReplicationBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

TestReplicationBase.ReplicationEndpointTest

Field Summary

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

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 Summary

Constructors

Constructor	Description
TestMigrateReplicationQueue()

Method Summary

Modifier and Type	Method	Description
private int	disableAndInsert()
private String	getQueuesZNode()
private void	mockData()
void	testMigrate()

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

addPeer, addPeer, cleanUp, createTable, getClusterKey, isSerialPeer, isSyncPeer, loadData, loadData, removePeer, removePeer, restartSourceCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, setupConfig, stopAllRegionServers, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TestMigrateReplicationQueue

public TestMigrateReplicationQueue()

Method Details

disableAndInsert

private int disableAndInsert()
                      throws Exception

Throws:

Exception

getQueuesZNode

private String getQueuesZNode()
                       throws IOException

Throws:

IOException

mockData

private void mockData()
               throws Exception

Throws:

Exception

testMigrate

@Test
public void testMigrate()
                 throws Exception

Throws:

Exception