public class TestReplicationLogCleaner extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner |
cleaner |
private static org.apache.hadoop.conf.Configuration |
CONF |
private org.apache.hadoop.hbase.master.MasterServices |
services |
Constructor and Description |
---|
TestReplicationLogCleaner() |
Modifier and Type | Method and Description |
---|---|
private void |
addPeer(String... peerIds) |
private void |
addQueueData(org.apache.hadoop.hbase.replication.ReplicationQueueData... datas) |
private void |
addSCP(org.apache.hadoop.hbase.ServerName serverName,
boolean finished) |
private void |
addServer(org.apache.hadoop.hbase.ServerName serverName) |
private static org.apache.hadoop.fs.FileStatus |
createFileStatus(org.apache.hadoop.fs.Path path) |
private static org.apache.hadoop.fs.FileStatus |
createFileStatus(org.apache.hadoop.hbase.ServerName sn,
int number) |
private static org.apache.hadoop.hbase.replication.ReplicationPeerDescription |
createPeer(String peerId) |
private static Iterable<org.apache.hadoop.fs.FileStatus> |
runCleaner(org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner,
Iterable<org.apache.hadoop.fs.FileStatus> files) |
void |
setUp() |
void |
tearDown() |
void |
testCanNotFilter() |
void |
testDeadRegionServerMissingQueue() |
void |
testDeadRegionServerNoQueues() |
void |
testDeadRegionServerShouldDelete() |
void |
testDeadRegionServerShouldDeleteTwoPeers() |
void |
testDeadRegionServerShouldNotDelete() |
void |
testDeadRegionServerShouldNotDeleteTwoPeers() |
void |
testDeadRegionServerWithSCPNoQueues() |
void |
testLiveRegionServerMissingQueue() |
void |
testLiveRegionServerNoQueues() |
void |
testLiveRegionServerShouldDelete() |
void |
testLiveRegionServerShouldDeleteTwoPeers() |
void |
testLiveRegionServerShouldNotDelete() |
void |
testLiveRegionServerShouldNotDeleteTwoPeers() |
void |
testLiveRegionServerWithSCPNoQueues() |
void |
testMetaWalFile() |
void |
testNoConf() |
void |
testNoPeer() |
void |
testNotValidWalFile() |
public static final HBaseClassTestRule CLASS_RULE
private static final org.apache.hadoop.conf.Configuration CONF
private org.apache.hadoop.hbase.master.MasterServices services
private org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner
public TestReplicationLogCleaner()
public void setUp() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void tearDown()
private static Iterable<org.apache.hadoop.fs.FileStatus> runCleaner(org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner, Iterable<org.apache.hadoop.fs.FileStatus> files)
private static org.apache.hadoop.fs.FileStatus createFileStatus(org.apache.hadoop.fs.Path path)
private static org.apache.hadoop.fs.FileStatus createFileStatus(org.apache.hadoop.hbase.ServerName sn, int number)
private static org.apache.hadoop.hbase.replication.ReplicationPeerDescription createPeer(String peerId)
private void addServer(org.apache.hadoop.hbase.ServerName serverName)
private void addSCP(org.apache.hadoop.hbase.ServerName serverName, boolean finished)
private void addQueueData(org.apache.hadoop.hbase.replication.ReplicationQueueData... datas) throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testNoConf()
public void testCanNotFilter()
public void testNoPeer()
public void testNotValidWalFile()
public void testMetaWalFile()
public void testLiveRegionServerNoQueues()
public void testLiveRegionServerWithSCPNoQueues()
public void testDeadRegionServerNoQueues()
public void testDeadRegionServerWithSCPNoQueues()
public void testLiveRegionServerMissingQueue() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testLiveRegionServerShouldNotDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testLiveRegionServerShouldNotDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testLiveRegionServerShouldDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testLiveRegionServerShouldDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testDeadRegionServerMissingQueue() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testDeadRegionServerShouldNotDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testDeadRegionServerShouldNotDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testDeadRegionServerShouldDelete() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testDeadRegionServerShouldDeleteTwoPeers() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.