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 and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
boolean	serialPeer

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

admin, 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 and Description
TestReplicationChangingPeerRegionservers()

Method Summary

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

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

addPeer, cleanUp, configureClusters, createTable, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

serialPeer

public boolean serialPeer

Constructor Detail

TestReplicationChangingPeerRegionservers

public TestReplicationChangingPeerRegionservers()

Method Detail

isSerialPeer

protected boolean isSerialPeer()

Overrides:

isSerialPeer in class TestReplicationBase

parameters

public static List<Boolean> 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