Package org.apache.hadoop.hbase.replication

Class TestReplicationStatus

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationStatus

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestReplicationStatus
extends TestReplicationBase

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

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

Method Summary

Modifier and Type	Method	Description
(package private) static void	insertRowsOnSource()
void	testReplicationStatus()	Test for HBASE-9531.
private List<org.apache.hadoop.hbase.replication.ReplicationLoadSource>	waitOnMetricsReport(int greaterThan, org.apache.hadoop.hbase.ServerName serverName)	Wait until Master shows metrics counts for ReplicationLoadSourceList that are greater than greaterThan for serverName before returning.

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, isSerialPeer, isSyncPeer, 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

Constructor Details

TestReplicationStatus

public TestReplicationStatus()

Method Details

insertRowsOnSource

static void insertRowsOnSource()
                        throws IOException

Throws:

IOException

testReplicationStatus

@Test
public void testReplicationStatus()
                           throws Exception

Test for HBASE-9531.

put a few rows into htable1, which should be replicated to htable2
create a ClusterStatus instance 'status' from HBaseAdmin
test : status.getLoad(server).getReplicationLoadSourceList()
test : status.getLoad(server).getReplicationLoadSink()

Throws:

Exception

waitOnMetricsReport

private List<org.apache.hadoop.hbase.replication.ReplicationLoadSource> waitOnMetricsReport(int greaterThan,
 org.apache.hadoop.hbase.ServerName serverName)
                                                                                     throws Exception

Wait until Master shows metrics counts for ReplicationLoadSourceList that are greater than greaterThan for serverName before returning. We want to avoid case where RS hasn't yet updated Master before allowing test proceed.

Parameters:

greaterThan - size of replicationLoadSourceList must be greater before we proceed

Throws:

Exception