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.

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, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, PEER_ID2, row, scopes, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2

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

cleanUp, loadData, loadData, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, tearDownAfterClass, tearDownBase, 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