Package org.apache.hadoop.hbase.replication

Class TestReplicationStatus

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationStatus

public class TestReplicationStatus
extends TestReplicationBase

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

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

addPeer, cleanUp, configureClusters, createTable, isSerialPeer, 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 Details

LOG

private static final org.slf4j.Logger LOG

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

Constructor Details

TestReplicationStatus

public TestReplicationStatus()

Method Details

insertRowsOnSource

static void insertRowsOnSource()
                        throws IOException

Throws:

IOException

testReplicationStatus

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