public class TestZKReplicationQueueStorage extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
org.junit.rules.TestName |
name |
private org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration |
storage |
private static HBaseZKTestingUtil |
UTIL |
private org.apache.hadoop.hbase.zookeeper.ZKWatcher |
zk |
Constructor and Description |
---|
TestZKReplicationQueueStorage() |
Modifier and Type | Method and Description |
---|---|
private static String |
getLastPushedSeqIdZNode(String regionsZNode,
String encodedName,
String peerId) |
static void |
mockHFileRefs(org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage,
int nPeers) |
static Map<String,Set<String>> |
mockLastPushedSeqIds(org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage,
String peerId1,
String peerId2,
int nRegions,
int emptyLevel1Count,
int emptyLevel2Count) |
static void |
mockQueuesData(org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage,
int nServers,
String peerId,
org.apache.hadoop.hbase.ServerName deadServer) |
void |
setUp() |
static void |
setUpBeforeClass() |
void |
tearDown() |
static void |
tearDownAfterClass() |
void |
testDeleteAllData() |
void |
testEmptyIter() |
void |
testListAllHFileRefs() |
void |
testListAllLastPushedSeqIds() |
void |
testListAllQueues() |
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseZKTestingUtil UTIL
private org.apache.hadoop.hbase.zookeeper.ZKWatcher zk
private org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage
public final org.junit.rules.TestName name
public TestZKReplicationQueueStorage()
public static void setUpBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws IOException
IOException
public void setUp() throws IOException
IOException
public static void mockQueuesData(org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage, int nServers, String peerId, org.apache.hadoop.hbase.ServerName deadServer) throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
private static String getLastPushedSeqIdZNode(String regionsZNode, String encodedName, String peerId)
public static Map<String,Set<String>> mockLastPushedSeqIds(org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage, String peerId1, String peerId2, int nRegions, int emptyLevel1Count, int emptyLevel2Count) throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
public static void mockHFileRefs(org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage, int nPeers) throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
public void testDeleteAllData() throws Exception
Exception
public void testEmptyIter() throws Exception
Exception
public void testListAllQueues() throws Exception
Exception
public void testListAllLastPushedSeqIds() throws Exception
Exception
public void testListAllHFileRefs() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.