Package org.apache.hadoop.hbase.replication

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

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private boolean	serialPeer
private boolean	syncPeer

Fields 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

Constructors

Constructor	Description
TestReplicationChangingPeerRegionservers(boolean serialPeer, boolean syncPeer)

Method Summary

Modifier and Type	Method	Description
private void	doPutTest(byte[] row)
protected boolean	isSerialPeer()
protected boolean	isSyncPeer()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
void	setUp()
void	testChangingNumberOfPeerRegionServers()

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

setUpBeforeClass

Methods 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

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

serialPeer

private boolean serialPeer

syncPeer

private boolean syncPeer

Constructor Details

TestReplicationChangingPeerRegionservers

public TestReplicationChangingPeerRegionservers(boolean serialPeer,
 boolean syncPeer)

Method Details

isSerialPeer

protected boolean isSerialPeer()

Overrides:

isSerialPeer in class TestReplicationBaseNoBeforeAll

isSyncPeer

protected boolean isSyncPeer()

Overrides:

isSyncPeer in class TestReplicationBaseNoBeforeAll

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

testChangingNumberOfPeerRegionServers

@TestTemplate
public void testChangingNumberOfPeerRegionServers()
                                           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

doPutTest

private void doPutTest(byte[] row)
                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException