public class TestReplicationChangingPeerRegionservers extends TestReplicationBase
TestReplicationBase.ReplicationEndpointTest
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
boolean |
serialPeer |
boolean |
syncPeer |
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 and Description |
---|
TestReplicationChangingPeerRegionservers() |
Modifier and Type | Method and Description |
---|---|
private void |
doPutTest(byte[] row) |
protected boolean |
isSerialPeer() |
protected boolean |
isSyncPeer() |
static List<Object[]> |
parameters() |
void |
setUp() |
void |
testChangingNumberOfPeerRegionServers() |
addPeer, cleanUp, configureClusters, createTable, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
public boolean serialPeer
public boolean syncPeer
public TestReplicationChangingPeerRegionservers()
protected boolean isSerialPeer()
isSerialPeer
in class TestReplicationBase
protected boolean isSyncPeer()
isSyncPeer
in class TestReplicationBase
public static List<Object[]> parameters()
public void testChangingNumberOfPeerRegionServers() throws IOException, InterruptedException
IOException
InterruptedException
private void doPutTest(byte[] row) throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.