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

Class TestRegionReplicaReplication

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestRegionReplicaReplication

@Tag("org.apache.hadoop.hbase.testclassification.FlakeyTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestRegionReplicaReplication
extends Object

Tests region replication by setting up region replicas and verifying async wal replication replays the edits to the secondary region in various scenarios.

Field Summary

Fields

Modifier and Type	Field	Description
private static final HBaseTestingUtil	HTU
private static final org.slf4j.Logger	LOG
private static final int	NB_SERVERS
private String	testName

Constructor Summary

Constructors

Constructor	Description
TestRegionReplicaReplication()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
static void	beforeClass()
private void	createOrEnableTableWithRetries(org.apache.hadoop.hbase.client.TableDescriptor htd, boolean createTableOperation)
private void	testRegionReplicaReplication(int regionReplication, boolean skipWAL)
void	testRegionReplicaReplicationForFlushAndCompaction(org.junit.jupiter.api.TestInfo testInfo)
void	testRegionReplicaReplicationWith10Replicas()
void	testRegionReplicaReplicationWith2Replicas()
void	testRegionReplicaReplicationWith3Replicas()
void	testRegionReplicaWithoutMemstoreReplication(org.junit.jupiter.api.TestInfo testInfo)
private void	verifyReplication(org.apache.hadoop.hbase.TableName tableName, int regionReplication, int startRow, int endRow)
private void	verifyReplication(org.apache.hadoop.hbase.TableName tableName, int regionReplication, int startRow, int endRow, boolean present)

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

NB_SERVERS

private static final int NB_SERVERS

See Also:

• Constant Field Values

HTU

private static final HBaseTestingUtil HTU

testName

private String testName

Constructor Details

TestRegionReplicaReplication

public TestRegionReplicaReplication()

Method Details

beforeClass

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

testRegionReplicaReplication

private void testRegionReplicaReplication(int regionReplication,
 boolean skipWAL)
                                   throws Exception

Throws:

Exception

verifyReplication

private void verifyReplication(org.apache.hadoop.hbase.TableName tableName,
 int regionReplication,
 int startRow,
 int endRow)
                        throws Exception

Throws:

Exception

verifyReplication

private void verifyReplication(org.apache.hadoop.hbase.TableName tableName,
 int regionReplication,
 int startRow,
 int endRow,
 boolean present)
                        throws Exception

Throws:

Exception

testRegionReplicaReplicationWith2Replicas

@Test
public void testRegionReplicaReplicationWith2Replicas()
                                               throws Exception

Throws:

Exception

testRegionReplicaReplicationWith3Replicas

@Test
public void testRegionReplicaReplicationWith3Replicas()
                                               throws Exception

Throws:

Exception

testRegionReplicaReplicationWith10Replicas

@Test
public void testRegionReplicaReplicationWith10Replicas()
                                                throws Exception

Throws:

Exception

testRegionReplicaWithoutMemstoreReplication

@Test
public void testRegionReplicaWithoutMemstoreReplication(org.junit.jupiter.api.TestInfo testInfo)
                                                 throws Exception

Throws:

Exception

testRegionReplicaReplicationForFlushAndCompaction

@Test
public void testRegionReplicaReplicationForFlushAndCompaction(org.junit.jupiter.api.TestInfo testInfo)
                                                       throws Exception

Throws:

Exception

createOrEnableTableWithRetries

private void createOrEnableTableWithRetries(org.apache.hadoop.hbase.client.TableDescriptor htd,
 boolean createTableOperation)