Package org.apache.hadoop.hbase.replication

Class TestZKReplicationQueueStorage

java.lang.Object

org.apache.hadoop.hbase.replication.TestZKReplicationQueueStorage

public class TestZKReplicationQueueStorage
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
final org.junit.rules.TestName	name
private org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration	storage
private static final HBaseZKTestingUtil	UTIL
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	zk

Constructor Summary

Constructors

Constructor	Description
TestZKReplicationQueueStorage()

Method Summary

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UTIL

private static final HBaseZKTestingUtil UTIL

zk

private org.apache.hadoop.hbase.zookeeper.ZKWatcher zk

storage

private org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage

name

public final org.junit.rules.TestName name

Constructor Details

TestZKReplicationQueueStorage

public TestZKReplicationQueueStorage()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws IOException

Throws:

IOException

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

mockQueuesData

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

Throws:

org.apache.zookeeper.KeeperException

getLastPushedSeqIdZNode

private static String getLastPushedSeqIdZNode(String regionsZNode,
 String encodedName,
 String peerId)

mockLastPushedSeqIds

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

Throws:

org.apache.zookeeper.KeeperException

mockHFileRefs

public static void mockHFileRefs(org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration storage,
 int nPeers)
                          throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

testDeleteAllData

public void testDeleteAllData()
                       throws Exception

Throws:

Exception

testEmptyIter

public void testEmptyIter()
                   throws Exception

Throws:

Exception

testListAllQueues

public void testListAllQueues()
                       throws Exception

Throws:

Exception

testListAllLastPushedSeqIds

public void testListAllLastPushedSeqIds()
                                 throws Exception

Throws:

Exception

testListAllHFileRefs

public void testListAllHFileRefs()
                          throws Exception

Throws:

Exception