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_KEY |
protected org.apache.hadoop.hbase.replication.ReplicationPeers |
rp |
protected org.apache.hadoop.hbase.ServerName |
server1 |
protected org.apache.hadoop.hbase.ServerName |
server2 |
protected org.apache.hadoop.hbase.ServerName |
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 |
---|---|
private void |
assertConnectedPeerStatus(boolean status,
String peerId) |
private void |
assertNumberOfPeers(int total) |
void |
testReplicationPeers() |
private static final org.slf4j.Logger LOG
protected org.apache.hadoop.hbase.ServerName server1
protected org.apache.hadoop.hbase.ServerName server2
protected org.apache.hadoop.hbase.ServerName server3
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
public TestReplicationStateBasic()
public void testReplicationPeers() throws Exception
Exception
private void assertConnectedPeerStatus(boolean status, String peerId) throws Exception
Exception
private void assertNumberOfPeers(int total) throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.