org.apache.hadoop.hbase.replication.regionserver

Class TestRegionReplicaReplicationEndpoint

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestRegionReplicaReplicationEndpoint

public class TestRegionReplicaReplicationEndpoint
extends Object

Tests RegionReplicaReplicationEndpoint class 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 and Description
static HBaseClassTestRule	CLASS_RULE
private static HBaseTestingUtility	HTU
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static int	NB_SERVERS

Constructor Summary

Constructors

Constructor and Description
TestRegionReplicaReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
static void	beforeClass()
private void	createOrEnableTableWithRetries(org.apache.hadoop.hbase.client.TableDescriptor htd, boolean createTableOperation)
void	testRegionReplicaReplication(int regionReplication)
void	testRegionReplicaReplicationForFlushAndCompaction()
void	testRegionReplicaReplicationIgnores(boolean dropTable, boolean disableReplication)
void	testRegionReplicaReplicationIgnoresDisabledTables()
void	testRegionReplicaReplicationIgnoresDroppedTables()
void	testRegionReplicaReplicationIgnoresNonReplicatedTables()
void	testRegionReplicaReplicationPeerIsCreated()
void	testRegionReplicaReplicationPeerIsCreatedForModifyTable()
void	testRegionReplicaReplicationWith10Replicas()
void	testRegionReplicaReplicationWith2Replicas()
void	testRegionReplicaReplicationWith3Replicas()
void	testRegionReplicaWithoutMemstoreReplication()
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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 HBaseTestingUtility HTU

name

public org.junit.rules.TestName name

Constructor Detail

TestRegionReplicaReplicationEndpoint

public TestRegionReplicaReplicationEndpoint()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

testRegionReplicaReplicationPeerIsCreated

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testRegionReplicaReplicationPeerIsCreatedForModifyTable

public void testRegionReplicaReplicationPeerIsCreatedForModifyTable()
                                                             throws Exception

Throws:

Exception

testRegionReplicaReplication

public void testRegionReplicaReplication(int regionReplication)
                                  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

public void testRegionReplicaReplicationWith2Replicas()
                                               throws Exception

Throws:

Exception

testRegionReplicaReplicationWith3Replicas

public void testRegionReplicaReplicationWith3Replicas()
                                               throws Exception

Throws:

Exception

testRegionReplicaReplicationWith10Replicas

public void testRegionReplicaReplicationWith10Replicas()
                                                throws Exception

Throws:

Exception

testRegionReplicaWithoutMemstoreReplication

public void testRegionReplicaWithoutMemstoreReplication()
                                                 throws Exception

Throws:

Exception

testRegionReplicaReplicationForFlushAndCompaction

public void testRegionReplicaReplicationForFlushAndCompaction()
                                                       throws Exception

Throws:

Exception

testRegionReplicaReplicationIgnoresDisabledTables

public void testRegionReplicaReplicationIgnoresDisabledTables()
                                                       throws Exception

Throws:

Exception

testRegionReplicaReplicationIgnoresDroppedTables

public void testRegionReplicaReplicationIgnoresDroppedTables()
                                                      throws Exception

Throws:

Exception

testRegionReplicaReplicationIgnoresNonReplicatedTables

public void testRegionReplicaReplicationIgnoresNonReplicatedTables()
                                                            throws Exception

Throws:

Exception

testRegionReplicaReplicationIgnores

public void testRegionReplicaReplicationIgnores(boolean dropTable,
                                                boolean disableReplication)
                                         throws Exception

Throws:

Exception

createOrEnableTableWithRetries

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