public class TestReplicationMarker extends Object
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.Modifier and Type | Class and Description |
---|---|
(package private) static class |
TestReplicationMarker.ReplicationSinkTrackerRow |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
conf1 |
private static org.apache.hadoop.conf.Configuration |
conf2 |
private static org.slf4j.Logger |
LOG |
private static HBaseTestingUtil |
utility1 |
private static HBaseTestingUtil |
utility2 |
Constructor and Description |
---|
TestReplicationMarker() |
Modifier and Type | Method and 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() |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static org.apache.hadoop.conf.Configuration conf1
private static org.apache.hadoop.conf.Configuration conf2
private static HBaseTestingUtil utility1
private static HBaseTestingUtil utility2
public TestReplicationMarker()
public static void setUpBeforeClass() throws Exception
Exception
private static void waitForReplicationTrackerTableCreation()
public void testReplicationMarkerRow() throws Exception
Exception
private List<TestReplicationMarker.ReplicationSinkTrackerRow> getRows(org.apache.hadoop.hbase.client.Connection connection) throws IOException
IOException
private TestReplicationMarker.ReplicationSinkTrackerRow getPayload(List<org.apache.hadoop.hbase.Cell> cells)
private int getTableCount(org.apache.hadoop.hbase.client.Connection connection) throws Exception
Exception
private long getReplicatedEntries()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.