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

Class TestSerialReplicationChecker

java.lang.Object

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

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

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.replication.regionserver.SerialReplicationChecker	checker
private org.apache.hadoop.hbase.client.Connection	conn
private static String	PEER_ID
private static org.apache.hadoop.hbase.replication.ReplicationQueueStorage	QUEUE_STORAGE
private org.apache.hadoop.hbase.TableName	tableName
private String	testName
private static final HBaseTestingUtil	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(org.junit.jupiter.api.TestInfo testInfo)
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

UTIL

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

testName

private String testName

tableName

private org.apache.hadoop.hbase.TableName tableName

Constructor Details

TestSerialReplicationChecker

public TestSerialReplicationChecker()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           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

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

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushUnder

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushIfContinuous

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushAfterMerge

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushAfterSplit

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testCanPushEqualsToBarrier

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException