Package org.apache.hadoop.hbase.replication.regionserver

Class TestSerialReplicationChecker

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestSerialReplicationChecker

public class TestSerialReplicationChecker
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.replication.regionserver.SerialReplicationChecker	checker
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.client.Connection	conn
final org.junit.rules.TestName	name
private static String	PEER_ID
private static org.apache.hadoop.hbase.replication.ReplicationQueueStorage	QUEUE_STORAGE
private org.apache.hadoop.hbase.TableName	tableName
private static final HBaseTestingUtility	UTIL
private static String	WAL_FILE_NAME

Constructor Summary

Constructors

Constructor	Description
TestSerialReplicationChecker()

Method Summary

Modifier and Type	Method	Description
private void	addParents(org.apache.hadoop.hbase.client.RegionInfo region, List<org.apache.hadoop.hbase.client.RegionInfo> parents)
private void	addStateAndBarrier(org.apache.hadoop.hbase.client.RegionInfo region, org.apache.hadoop.hbase.master.RegionState.State state, long... barriers)
private org.apache.hadoop.hbase.Cell	createCell(org.apache.hadoop.hbase.client.RegionInfo region)
private org.apache.hadoop.hbase.wal.WAL.Entry	createEntry(org.apache.hadoop.hbase.client.RegionInfo region, long seqId)
private void	setState(org.apache.hadoop.hbase.client.RegionInfo region, org.apache.hadoop.hbase.master.RegionState.State state)
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCanPushAfterMerge()
void	testCanPushAfterSplit()
void	testCanPushEqualsToBarrier()
void	testCanPushIfContinuous()
void	testCanPushUnder()
void	testLastRegionAndOpeningCanNotPush()
void	testNoBarrierCanPush()
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_ID

private static String PEER_ID

QUEUE_STORAGE

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

WAL_FILE_NAME

private static String WAL_FILE_NAME

conn

private org.apache.hadoop.hbase.client.Connection conn

checker

private org.apache.hadoop.hbase.replication.regionserver.SerialReplicationChecker checker

name

public final org.junit.rules.TestName name

tableName

private org.apache.hadoop.hbase.TableName tableName

Constructor Details

TestSerialReplicationChecker

public TestSerialReplicationChecker()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws IOException

Throws:

IOException

createEntry

private org.apache.hadoop.hbase.wal.WAL.Entry createEntry(org.apache.hadoop.hbase.client.RegionInfo region,
 long seqId)

createCell

private org.apache.hadoop.hbase.Cell createCell(org.apache.hadoop.hbase.client.RegionInfo region)

testNoBarrierCanPush

public void testNoBarrierCanPush()
                          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

setState

private void setState(org.apache.hadoop.hbase.client.RegionInfo region,
 org.apache.hadoop.hbase.master.RegionState.State state)
               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

addParents

private void addParents(org.apache.hadoop.hbase.client.RegionInfo region,
 List<org.apache.hadoop.hbase.client.RegionInfo> parents)
                 throws IOException

Throws:

IOException

testLastRegionAndOpeningCanNotPush

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushUnder

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushIfContinuous

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushAfterMerge

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushAfterSplit

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushEqualsToBarrier

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException