Class TestReplicationChangingPeerRegionservers
java.lang.Object
org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
org.apache.hadoop.hbase.replication.TestReplicationBase
org.apache.hadoop.hbase.replication.TestReplicationChangingPeerRegionservers
@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestReplicationChangingPeerRegionservers
extends TestReplicationBase
Test handling of changes to the number of a peer's regionservers.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
TestReplicationBaseNoBeforeAll.ReplicationEndpointTest -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final org.slf4j.Loggerprivate booleanprivate booleanFields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
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
ConstructorsConstructorDescriptionTestReplicationChangingPeerRegionservers(boolean serialPeer, boolean syncPeer) -
Method Summary
Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase
setUpBeforeClassMethods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
addPeer, addPeer, cleanUp, configureClusters, createTable, getClusterKey, loadData, loadData, removePeer, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, startClusters, stopAllRegionServers, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication
-
Field Details
-
LOG
-
serialPeer
-
syncPeer
-
-
Constructor Details
-
TestReplicationChangingPeerRegionservers
-
-
Method Details
-
isSerialPeer
- Overrides:
isSerialPeerin classTestReplicationBaseNoBeforeAll
-
isSyncPeer
- Overrides:
isSyncPeerin classTestReplicationBaseNoBeforeAll
-
parameters
-
setUp
- Throws:
Exception
-
testChangingNumberOfPeerRegionServers
@TestTemplate public void testChangingNumberOfPeerRegionServers() throws IOException, InterruptedException- Throws:
IOExceptionInterruptedException
-
doPutTest
- Throws:
IOExceptionInterruptedException
-