Package org.apache.hadoop.hbase.master.replication

Class TestReplicationPeerManagerMigrateQueuesFromZk

java.lang.Object

org.apache.hadoop.hbase.master.replication.TestReplicationPeerManagerMigrateQueuesFromZk

public class TestReplicationPeerManagerMigrateQueuesFromZk
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.ServerName	deadServerName
private static ExecutorService	EXECUTOR
private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager	manager
private int	nPeers
private int	nRegions
private int	nServers
(package private) ConcurrentMap<String,org.apache.hadoop.hbase.replication.ReplicationPeerDescription>	peers
private org.apache.hadoop.hbase.replication.ReplicationPeerStorage	peerStorage
private org.apache.hadoop.hbase.replication.ReplicationQueueStorage	queueStorage
private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager.ReplicationQueueStorageInitializer	queueStorageInitializer
final TableNameTestRule	tableNameRule
private static HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestReplicationPeerManagerMigrateQueuesFromZk()

Method Summary

Modifier and Type	Method	Description
private Map<String,Set<String>>	prepareData()
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testMigrate()
void	testNoPeers()

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 HBaseTestingUtil UTIL

EXECUTOR

private static ExecutorService EXECUTOR

peers

ConcurrentMap<String,org.apache.hadoop.hbase.replication.ReplicationPeerDescription> peers

peerStorage

private org.apache.hadoop.hbase.replication.ReplicationPeerStorage peerStorage

queueStorage

private org.apache.hadoop.hbase.replication.ReplicationQueueStorage queueStorage

queueStorageInitializer

private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager.ReplicationQueueStorageInitializer queueStorageInitializer

manager

private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager manager

nServers

private int nServers

nPeers

private int nPeers

nRegions

private int nRegions

deadServerName

private org.apache.hadoop.hbase.ServerName deadServerName

tableNameRule

public final TableNameTestRule tableNameRule

Constructor Details

TestReplicationPeerManagerMigrateQueuesFromZk

public TestReplicationPeerManagerMigrateQueuesFromZk()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws IOException

Throws:

IOException

prepareData

private Map<String,Set<String>> prepareData()
                                     throws Exception

Throws:

Exception

testNoPeers

public void testNoPeers()
                 throws Exception

Throws:

Exception

testMigrate

public void testMigrate()
                 throws Exception

Throws:

Exception