Package org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationMarker

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicationMarker

public class TestReplicationMarker
extends Object

This test creates 2 mini hbase cluster. One cluster with "hbase.regionserver.replication.marker.enabled" conf key. This will create ReplicationMarkerChore which will create marker rows to be replicated to sink cluster. Second cluster with "hbase.regionserver.replication.sink.tracker.enabled" conf key enabled. This will persist the marker rows coming from peer cluster to persist to REPLICATION.SINK_TRACKER table.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	TestReplicationMarker.ReplicationSinkTrackerRow

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	conf1
private static org.apache.hadoop.conf.Configuration	conf2
private static final org.slf4j.Logger	LOG
private static HBaseTestingUtil	utility1
private static HBaseTestingUtil	utility2

Constructor Summary

Constructors

Constructor	Description
TestReplicationMarker()

Method Summary

Modifier and Type	Method	Description
private TestReplicationMarker.ReplicationSinkTrackerRow	getPayload(List<org.apache.hadoop.hbase.Cell> cells)
private long	getReplicatedEntries()
private List<TestReplicationMarker.ReplicationSinkTrackerRow>	getRows(org.apache.hadoop.hbase.client.Connection connection)
private int	getTableCount(org.apache.hadoop.hbase.client.Connection connection)
static void	setUpBeforeClass()
static void	tearDown()
void	testReplicationMarkerRow()
private static void	waitForReplicationTrackerTableCreation()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

conf1

private static org.apache.hadoop.conf.Configuration conf1

conf2

private static org.apache.hadoop.conf.Configuration conf2

utility1

private static HBaseTestingUtil utility1

utility2

private static HBaseTestingUtil utility2

Constructor Details

TestReplicationMarker

public TestReplicationMarker()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

waitForReplicationTrackerTableCreation

private static void waitForReplicationTrackerTableCreation()

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

testReplicationMarkerRow

public void testReplicationMarkerRow()
                              throws Exception

Throws:

Exception

getRows

private List<TestReplicationMarker.ReplicationSinkTrackerRow> getRows(org.apache.hadoop.hbase.client.Connection connection)
                                                               throws IOException

Throws:

IOException

getPayload

private TestReplicationMarker.ReplicationSinkTrackerRow getPayload(List<org.apache.hadoop.hbase.Cell> cells)

getTableCount

private int getTableCount(org.apache.hadoop.hbase.client.Connection connection)
                   throws Exception

Throws:

Exception

getReplicatedEntries

private long getReplicatedEntries()