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.

Constructor Summary

Constructors

Constructor and Description
TestRegionReplicaReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
static void	beforeClass()
void	testRegionReplicaReplication(int regionReplication)
void	testRegionReplicaReplicationForFlushAndCompaction()
void	testRegionReplicaReplicationIgnoresDisabledTables()
void	testRegionReplicaReplicationIgnoresDisabledTables(boolean dropTable)
void	testRegionReplicaReplicationIgnoresDroppedTables()
void	testRegionReplicaReplicationPeerIsCreated()
void	testRegionReplicaReplicationPeerIsCreatedForModifyTable()
void	testRegionReplicaReplicationWith10Replicas()
void	testRegionReplicaReplicationWith2Replicas()
void	testRegionReplicaReplicationWith3Replicas()
void	testRegionReplicaWithoutMemstoreReplication()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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,
                                                      ReplicationException

Throws:

IOException

ReplicationException

testRegionReplicaReplicationPeerIsCreatedForModifyTable

public void testRegionReplicaReplicationPeerIsCreatedForModifyTable()
                                                             throws Exception

Throws:

Exception

testRegionReplicaReplication

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

testRegionReplicaReplicationIgnoresDisabledTables

public void testRegionReplicaReplicationIgnoresDisabledTables(boolean dropTable)
                                                       throws Exception

Throws:

Exception