public class TestReplicationStateZKImpl extends TestReplicationStateBasic
Modifier and Type | Class and Description |
---|---|
(package private) static class |
TestReplicationStateZKImpl.DummyServer |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
conf |
private static org.slf4j.Logger |
LOG |
private static String |
replicationZNode |
private org.apache.hadoop.hbase.replication.ReplicationQueuesZKImpl |
rqZK |
private static HBaseTestingUtility |
utility |
private static org.apache.hadoop.hbase.zookeeper.ZKWatcher |
zkw |
ID_ONE, ID_TWO, KEY_ONE, KEY_TWO, OUR_ID, OUR_KEY, rp, rq1, rq2, rq3, rqc, server1, server2, server3, ZK_MAX_COUNT, ZK_SLEEP_INTERVAL, zkTimeoutCount
Constructor and Description |
---|
TestReplicationStateZKImpl() |
Modifier and Type | Method and Description |
---|---|
private static String |
initPeerClusterState(String baseZKNode) |
void |
setUp() |
static void |
setUpBeforeClass() |
void |
tearDown() |
static void |
tearDownAfterClass() |
void |
testIsPeerPath_ActualPeerPath() |
void |
testIsPeerPath_PathToChildOfPeerNode() |
void |
testIsPeerPath_PathToParentOfPeerNode() |
assertConnectedPeerStatus, assertNumberOfPeers, populateQueues, testHfileRefsReplicationQueues, testInvalidClusterKeys, testRemovePeerForHFileRefs, testReplicationPeers, testReplicationQueues, testReplicationQueuesClient
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static org.apache.hadoop.conf.Configuration conf
private static HBaseTestingUtility utility
private static org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw
private static String replicationZNode
private org.apache.hadoop.hbase.replication.ReplicationQueuesZKImpl rqZK
public TestReplicationStateZKImpl()
public static void setUpBeforeClass() throws Exception
Exception
private static String initPeerClusterState(String baseZKNode) throws IOException, org.apache.zookeeper.KeeperException
IOException
org.apache.zookeeper.KeeperException
public void setUp()
setUp
in class TestReplicationStateBasic
public void tearDown() throws org.apache.zookeeper.KeeperException, IOException
org.apache.zookeeper.KeeperException
IOException
public static void tearDownAfterClass() throws Exception
Exception
public void testIsPeerPath_PathToParentOfPeerNode()
public void testIsPeerPath_PathToChildOfPeerNode()
public void testIsPeerPath_ActualPeerPath()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.