public class TestReplicationPeerManagerMigrateQueuesFromZk extends Object
Modifier and Type | Field and Description |
---|---|
static 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 |
TableNameTestRule |
tableNameRule |
private static HBaseTestingUtil |
UTIL |
Constructor and Description |
---|
TestReplicationPeerManagerMigrateQueuesFromZk() |
Modifier and Type | Method and Description |
---|---|
private Map<String,Set<String>> |
prepareData() |
void |
setUp() |
static void |
setUpBeforeClass() |
static void |
tearDownAfterClass() |
void |
testMigrate() |
void |
testNoPeers() |
public static final HBaseClassTestRule CLASS_RULE
private static HBaseTestingUtil UTIL
private static ExecutorService EXECUTOR
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
private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager manager
private int nServers
private int nPeers
private int nRegions
private org.apache.hadoop.hbase.ServerName deadServerName
public final TableNameTestRule tableNameRule
public TestReplicationPeerManagerMigrateQueuesFromZk()
public static void setUpBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws Exception
Exception
public void setUp() throws IOException
IOException
public void testNoPeers() throws Exception
Exception
public void testMigrate() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.