public class TestReplicationStateZKImpl extends TestReplicationStateBasic
| Modifier and Type | Field and Description |
|---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
conf |
private static String |
replicationZNode |
private static HBaseZKTestingUtility |
utility |
private static org.apache.hadoop.hbase.zookeeper.ZKWatcher |
zkw |
ID_ONE, ID_TWO, KEY_ONE, KEY_TWO, OUR_KEY, rp, rqs, 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() |
assertConnectedPeerStatus, assertNumberOfPeers, populateQueues, testHfileRefsReplicationQueues, testPersistLogPositionAndSeqIdAtomically, testRemovePeerForHFileRefs, testReplicationPeers, testReplicationQueues, testReplicationQueueStoragepublic static final HBaseClassTestRule CLASS_RULE
private static org.apache.hadoop.conf.Configuration conf
private static HBaseZKTestingUtility utility
private static org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw
private static String replicationZNode
public TestReplicationStateZKImpl()
public static void setUpBeforeClass() throws Exception
Exceptionprivate static String initPeerClusterState(String baseZKNode) throws IOException, org.apache.zookeeper.KeeperException
IOExceptionorg.apache.zookeeper.KeeperExceptionpublic void setUp()
public void tearDown() throws org.apache.zookeeper.KeeperException, IOException
org.apache.zookeeper.KeeperExceptionIOExceptionpublic static void tearDownAfterClass() throws Exception
ExceptionCopyright © 2007–2021 The Apache Software Foundation. All rights reserved.