Package org.apache.hadoop.hbase.master.cleaner

Class TestReplicationBarrierCleaner

java.lang.Object

org.apache.hadoop.hbase.master.cleaner.TestReplicationBarrierCleaner

public class TestReplicationBarrierCleaner
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestReplicationBarrierCleaner.WarnOnlyStoppable

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG
final org.junit.rules.TestName	name
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestReplicationBarrierCleaner()

Method Summary

Modifier and Type	Method	Description
private void	addBarrier(org.apache.hadoop.hbase.client.RegionInfo region, long... barriers)
private void	clearCatalogFamily(org.apache.hadoop.hbase.client.RegionInfo region)
private org.apache.hadoop.hbase.replication.ReplicationQueueStorage	create(Long lastPushedSeqId, Long... lastPushedSeqIds)
private org.apache.hadoop.hbase.master.cleaner.ReplicationBarrierCleaner	create(org.apache.hadoop.hbase.master.replication.ReplicationPeerManager peerManager)
private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager	create(org.apache.hadoop.hbase.replication.ReplicationQueueStorage queueStorage, List<String> firstPeerIds, List<String>... peerIds)
private void	fillCatalogFamily(org.apache.hadoop.hbase.client.RegionInfo region)
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testCleanNoPeers()
void	testDeleteBarriers()
void	testDeleteRowForDeletedRegion()
void	testDeleteRowForDeletedRegionNoPeers()
void	testNothing()

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

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtil UTIL

name

public final org.junit.rules.TestName name

Constructor Details

TestReplicationBarrierCleaner

public TestReplicationBarrierCleaner()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

create

private org.apache.hadoop.hbase.master.replication.ReplicationPeerManager create(org.apache.hadoop.hbase.replication.ReplicationQueueStorage queueStorage,
 List<String> firstPeerIds,
 List<String>... peerIds)

create

private org.apache.hadoop.hbase.replication.ReplicationQueueStorage create(Long lastPushedSeqId,
 Long... lastPushedSeqIds)
                                                                    throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

create

private org.apache.hadoop.hbase.master.cleaner.ReplicationBarrierCleaner create(org.apache.hadoop.hbase.master.replication.ReplicationPeerManager peerManager)
                                                                         throws IOException

Throws:

IOException

addBarrier

private void addBarrier(org.apache.hadoop.hbase.client.RegionInfo region,
 long... barriers)
                 throws IOException

Throws:

IOException

fillCatalogFamily

private void fillCatalogFamily(org.apache.hadoop.hbase.client.RegionInfo region)
                        throws IOException

Throws:

IOException

clearCatalogFamily

private void clearCatalogFamily(org.apache.hadoop.hbase.client.RegionInfo region)
                         throws IOException

Throws:

IOException

testNothing

public void testNothing()
                 throws IOException

Throws:

IOException

testCleanNoPeers

public void testCleanNoPeers()
                      throws IOException

Throws:

IOException

testDeleteBarriers

public void testDeleteBarriers()
                        throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testDeleteRowForDeletedRegion

public void testDeleteRowForDeletedRegion()
                                   throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testDeleteRowForDeletedRegionNoPeers

public void testDeleteRowForDeletedRegionNoPeers()
                                          throws IOException

Throws:

IOException