public abstract class TestReplicationStateBasic extends Object
Modifier and Type | Field and Description |
---|---|
protected static String |
ID_ONE |
protected static String |
ID_TWO |
protected static String |
KEY_ONE |
protected static String |
KEY_TWO |
private static org.slf4j.Logger |
LOG |
protected String |
OUR_ID |
protected String |
OUR_KEY |
protected org.apache.hadoop.hbase.replication.ReplicationPeers |
rp |
protected org.apache.hadoop.hbase.replication.ReplicationQueues |
rq1 |
protected org.apache.hadoop.hbase.replication.ReplicationQueues |
rq2 |
protected org.apache.hadoop.hbase.replication.ReplicationQueues |
rq3 |
protected org.apache.hadoop.hbase.replication.ReplicationQueuesClient |
rqc |
protected String |
server1 |
protected String |
server2 |
protected String |
server3 |
protected static int |
ZK_MAX_COUNT |
protected static int |
ZK_SLEEP_INTERVAL |
protected static int |
zkTimeoutCount |
Constructor and Description |
---|
TestReplicationStateBasic() |
Modifier and Type | Method and Description |
---|---|
protected void |
assertConnectedPeerStatus(boolean status,
String peerId) |
protected void |
assertNumberOfPeers(int total) |
protected void |
populateQueues() |
void |
setUp() |
void |
testHfileRefsReplicationQueues() |
void |
testInvalidClusterKeys() |
void |
testRemovePeerForHFileRefs() |
void |
testReplicationPeers() |
void |
testReplicationQueues() |
void |
testReplicationQueuesClient() |
protected org.apache.hadoop.hbase.replication.ReplicationQueues rq1
protected org.apache.hadoop.hbase.replication.ReplicationQueues rq2
protected org.apache.hadoop.hbase.replication.ReplicationQueues rq3
protected org.apache.hadoop.hbase.replication.ReplicationQueuesClient rqc
protected org.apache.hadoop.hbase.replication.ReplicationPeers rp
protected static final String ID_ONE
protected static final String ID_TWO
protected static int zkTimeoutCount
protected static final int ZK_MAX_COUNT
protected static final int ZK_SLEEP_INTERVAL
private static final org.slf4j.Logger LOG
public TestReplicationStateBasic()
public void setUp()
public void testReplicationQueuesClient() throws org.apache.hadoop.hbase.replication.ReplicationException, org.apache.zookeeper.KeeperException
org.apache.hadoop.hbase.replication.ReplicationException
org.apache.zookeeper.KeeperException
public void testReplicationQueues() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testInvalidClusterKeys() throws org.apache.hadoop.hbase.replication.ReplicationException, org.apache.zookeeper.KeeperException
org.apache.hadoop.hbase.replication.ReplicationException
org.apache.zookeeper.KeeperException
public void testHfileRefsReplicationQueues() throws org.apache.hadoop.hbase.replication.ReplicationException, org.apache.zookeeper.KeeperException
org.apache.hadoop.hbase.replication.ReplicationException
org.apache.zookeeper.KeeperException
public void testRemovePeerForHFileRefs() throws org.apache.hadoop.hbase.replication.ReplicationException, org.apache.zookeeper.KeeperException
org.apache.hadoop.hbase.replication.ReplicationException
org.apache.zookeeper.KeeperException
public void testReplicationPeers() throws Exception
Exception
protected void assertConnectedPeerStatus(boolean status, String peerId) throws Exception
Exception
protected void assertNumberOfPeers(int total)
protected void populateQueues() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.