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

Class TestReplicationBarrierCleaner

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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
private static final org.slf4j.Logger	LOG
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(org.junit.jupiter.api.TestInfo testInfo)
void	testDeleteBarriers(org.junit.jupiter.api.TestInfo testInfo)
void	testDeleteRowForDeletedRegion(org.junit.jupiter.api.TestInfo testInfo)
void	testDeleteRowForDeletedRegionNoPeers(org.junit.jupiter.api.TestInfo testInfo)
void	testNothing()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtil UTIL

Constructor Details

TestReplicationBarrierCleaner

public TestReplicationBarrierCleaner()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

tearDown

@AfterEach
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

@Test
public void testNothing()
                 throws IOException

Throws:

IOException

testCleanNoPeers

@Test
public void testCleanNoPeers(org.junit.jupiter.api.TestInfo testInfo)
                      throws IOException

Throws:

IOException

testDeleteBarriers

@Test
public void testDeleteBarriers(org.junit.jupiter.api.TestInfo testInfo)
                        throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testDeleteRowForDeletedRegion

@Test
public void testDeleteRowForDeletedRegion(org.junit.jupiter.api.TestInfo testInfo)
                                   throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testDeleteRowForDeletedRegionNoPeers

@Test
public void testDeleteRowForDeletedRegionNoPeers(org.junit.jupiter.api.TestInfo testInfo)
                                          throws IOException

Throws:

IOException