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

Class TestReplicationPeerManagerMigrateQueuesFromZk

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestReplicationPeerManagerMigrateQueuesFromZk
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
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 TableNameTestExtension	tableNameExtension
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

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

tableNameExtension

@RegisterExtension
public final TableNameTestExtension tableNameExtension

Constructor Details

TestReplicationPeerManagerMigrateQueuesFromZk

public TestReplicationPeerManagerMigrateQueuesFromZk()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp()
           throws IOException

Throws:

IOException

prepareData

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

Throws:

Exception

testNoPeers

@Test
public void testNoPeers()
                 throws Exception

Throws:

Exception

testMigrate

@Test
public void testMigrate()
                 throws Exception

Throws:

Exception