Package org.apache.hadoop.hbase.util

Class TestHBaseFsckCleanReplicationBarriers

java.lang.Object

org.apache.hadoop.hbase.util.TestHBaseFsckCleanReplicationBarriers

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

Field Summary

Fields

Modifier and Type	Field	Description
private static String	COLUMN_FAMILY
private static String	PEER_1
private static String	PEER_2
private static org.apache.hadoop.hbase.replication.ReplicationQueueStorage	QUEUE_STORAGE
private static String	TABLE_NAME
private static final HBaseTestingUtil	UTIL
private static String	WAL_FILE_NAME

Constructor Summary

Constructors

Constructor	Description
TestHBaseFsckCleanReplicationBarriers()

Method Summary

Modifier and Type	Method	Description
private void	addStateAndBarrier(org.apache.hadoop.hbase.client.RegionInfo region, org.apache.hadoop.hbase.master.RegionState.State state, long... barriers)
static void	createPeer()
static void	setUp()
static void	tearDown()
void	testCleanReplicationBarrierWithDeletedTable()
void	testCleanReplicationBarrierWithExistTable()
void	testCleanReplicationBarrierWithNonExistTable()
private void	updatePushedSeqId(org.apache.hadoop.hbase.client.RegionInfo region, long seqId)

Methods inherited from class java.lang.Object

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

Field Details

UTIL

private static final HBaseTestingUtil UTIL

PEER_1

private static String PEER_1

PEER_2

private static String PEER_2

QUEUE_STORAGE

private static org.apache.hadoop.hbase.replication.ReplicationQueueStorage QUEUE_STORAGE

WAL_FILE_NAME

private static String WAL_FILE_NAME

TABLE_NAME

private static String TABLE_NAME

COLUMN_FAMILY

private static String COLUMN_FAMILY

Constructor Details

TestHBaseFsckCleanReplicationBarriers

public TestHBaseFsckCleanReplicationBarriers()

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

testCleanReplicationBarrierWithNonExistTable

@Test
public void testCleanReplicationBarrierWithNonExistTable()
                                                  throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

testCleanReplicationBarrierWithDeletedTable

@Test
public void testCleanReplicationBarrierWithDeletedTable()
                                                 throws Exception

Throws:

Exception

testCleanReplicationBarrierWithExistTable

@Test
public void testCleanReplicationBarrierWithExistTable()
                                               throws Exception

Throws:

Exception

createPeer

public static void createPeer()
                       throws IOException

Throws:

IOException

addStateAndBarrier

private void addStateAndBarrier(org.apache.hadoop.hbase.client.RegionInfo region,
 org.apache.hadoop.hbase.master.RegionState.State state,
 long... barriers)
                         throws IOException

Throws:

IOException

updatePushedSeqId

private void updatePushedSeqId(org.apache.hadoop.hbase.client.RegionInfo region,
 long seqId)
                        throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException