Package org.apache.hadoop.hbase.replication

Class TestReplicationChangingPeerRegionservers

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationChangingPeerRegionservers

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.TestReplicationBase

TestReplicationBase.ReplicationEndpointTest

Field Summary

Fields

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

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
TestReplicationChangingPeerRegionservers()

Method Summary

Modifier and Type	Method	Description
private void	doPutTest(byte[] row)
protected boolean	isSerialPeer()
protected boolean	isSyncPeer()
static List<Object[]>	parameters()
void	setUp()
void	testChangingNumberOfPeerRegionServers()

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

addPeer, cleanUp, configureClusters, createTable, getClusterKey, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, 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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

serialPeer

public boolean serialPeer

syncPeer

public boolean syncPeer

Constructor Details

TestReplicationChangingPeerRegionservers

public TestReplicationChangingPeerRegionservers()

Method Details

isSerialPeer

protected boolean isSerialPeer()

Overrides:

isSerialPeer in class TestReplicationBase

isSyncPeer

protected boolean isSyncPeer()

Overrides:

isSyncPeer in class TestReplicationBase

parameters

public static List<Object[]> parameters()

setUp

public void setUp()
           throws Exception

Throws:

Exception

testChangingNumberOfPeerRegionServers

public void testChangingNumberOfPeerRegionServers()
                                           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

doPutTest

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

Throws:

IOException

InterruptedException