Package org.apache.hadoop.hbase.util

Class TestHBaseFsckCleanReplicationBarriers

java.lang.Object

org.apache.hadoop.hbase.util.TestHBaseFsckCleanReplicationBarriers

public class TestHBaseFsckCleanReplicationBarriers
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
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 HBaseTestingUtility	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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UTIL

private static final HBaseTestingUtility 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

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

testCleanReplicationBarrierWithNonExistTable

public void testCleanReplicationBarrierWithNonExistTable()
                                                  throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

testCleanReplicationBarrierWithDeletedTable

public void testCleanReplicationBarrierWithDeletedTable()
                                                 throws Exception

Throws:

Exception

testCleanReplicationBarrierWithExistTable

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