public class TestReplicationSourceManager extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TestReplicationSourceManager.ReplicationEndpointForTest |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
CONF |
private static byte[] |
F1 |
private static byte[] |
F2 |
private static org.apache.hadoop.fs.FileSystem |
FS |
private org.apache.hadoop.fs.Path |
logDir |
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager |
manager |
org.junit.rules.TestName |
name |
private org.apache.hadoop.fs.Path |
oldLogDir |
private org.apache.hadoop.fs.Path |
remoteLogDir |
private org.apache.hadoop.hbase.replication.regionserver.Replication |
replication |
private static org.apache.hadoop.hbase.client.RegionInfo |
RI |
private static NavigableMap<byte[],Integer> |
SCOPES |
private org.apache.hadoop.hbase.Server |
server |
private static org.apache.hadoop.hbase.TableName |
TABLE_NAME |
private static HBaseTestingUtil |
UTIL |
Constructor and Description |
---|
TestReplicationSourceManager() |
Modifier and Type | Method and Description |
---|---|
private void |
addPeerAndWait(String peerId,
String clusterKey,
boolean syncRep)
Add a peer and wait for it to initialize
|
private void |
createWALFile(org.apache.hadoop.fs.Path file) |
private org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource |
getGlobalSource() |
private void |
removePeerAndWait(String peerId)
Remove a peer and wait for it to get cleaned up
|
void |
setUp() |
static void |
setUpBeforeClass() |
void |
tearDown() |
static void |
tearDownAfterClass() |
void |
testClaimQueue() |
void |
testDisablePeerMetricsCleanup() |
void |
testRemovePeerMetricsCleanup() |
void |
testRemoveRemoteWALs() |
void |
testSameWALPrefix() |
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtil UTIL
private static org.apache.hadoop.conf.Configuration CONF
private static org.apache.hadoop.fs.FileSystem FS
private static final byte[] F1
private static final byte[] F2
private static final org.apache.hadoop.hbase.TableName TABLE_NAME
private static org.apache.hadoop.hbase.client.RegionInfo RI
private static NavigableMap<byte[],Integer> SCOPES
public final org.junit.rules.TestName name
private org.apache.hadoop.fs.Path oldLogDir
private org.apache.hadoop.fs.Path logDir
private org.apache.hadoop.fs.Path remoteLogDir
private org.apache.hadoop.hbase.Server server
private org.apache.hadoop.hbase.replication.regionserver.Replication replication
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager
public TestReplicationSourceManager()
public static void setUpBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws IOException
IOException
public void tearDown()
private void addPeerAndWait(String peerId, String clusterKey, boolean syncRep) throws org.apache.hadoop.hbase.replication.ReplicationException, IOException
org.apache.hadoop.hbase.replication.ReplicationException
IOException
private void removePeerAndWait(String peerId) throws Exception
Exception
private void createWALFile(org.apache.hadoop.fs.Path file) throws Exception
Exception
public void testClaimQueue() throws Exception
Exception
public void testSameWALPrefix() throws IOException
IOException
private org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource getGlobalSource()
public void testRemovePeerMetricsCleanup() throws Exception
Exception
public void testDisablePeerMetricsCleanup() throws Exception
Exception
public void testRemoveRemoteWALs() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.