Package org.apache.hadoop.hbase.replication

Class TestReplicationSmallTests

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationSmallTests

public class TestReplicationSmallTests
extends TestReplicationBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

TestReplicationBase.ReplicationEndpointTest

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG
private static final String	PEER_ID
boolean	serialPeer

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

admin, CONF_WITH_LOCALFS, CONF1, CONF2, connection1, connection2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, replicateCount, replicatedEntries, row, SLEEP_TIME, tableName, UTIL1, UTIL2

Constructor Summary

Constructors

Constructor	Description
TestReplicationSmallTests()

Method Summary

Modifier and Type	Method	Description
protected boolean	isSerialPeer()
static List<Boolean>	parameters()
void	setUp()
void	testAddAndRemoveClusters()	Integration test for TestReplicationAdmin, removes and re-add a peer cluster
void	testDeleteTypes()	Verify that version and column delete marker types are replicated correctly.
void	testDisableEnable()	Test disable/enable replication, trying to insert, make sure nothing's replicated, enable it, the insert should be replicated
void	testGetReplicationPeerState()	Test for HBASE-27448 Add an admin method to get replication enabled state
void	testLoading()	Do a more intense version testSmallBatch, one that will trigger wal rolling and other non-trivial code paths
void	testReplicationInReplay()	Test for HBase-15259 WALEdits under replay will also be replicated
void	testSimplePutDelete()	Add a row, check it's replicated, delete it, check's gone
void	testSmallBatch()	Try a small batch upload using the write buffer, check it's replicated
void	testVerifyListReplicatedTable()	Test for HBASE-8663

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

addPeer, cleanUp, configureClusters, createTable, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication

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

LOG

private static final org.slf4j.Logger LOG

PEER_ID

private static final String PEER_ID

See Also:

• Constant Field Values

serialPeer

public boolean serialPeer

Constructor Details

TestReplicationSmallTests

public TestReplicationSmallTests()

Method Details

isSerialPeer

protected boolean isSerialPeer()

Overrides:

isSerialPeer in class TestReplicationBase

parameters

public static List<Boolean> parameters()

setUp

public void setUp()
           throws Exception

Throws:

Exception

testDeleteTypes

public void testDeleteTypes()
                     throws Exception

Verify that version and column delete marker types are replicated correctly.

Throws:

Exception

testSimplePutDelete

public void testSimplePutDelete()
                         throws Exception

Add a row, check it's replicated, delete it, check's gone

Throws:

Exception

testSmallBatch

public void testSmallBatch()
                    throws Exception

Try a small batch upload using the write buffer, check it's replicated

Throws:

Exception

testDisableEnable

public void testDisableEnable()
                       throws Exception

Test disable/enable replication, trying to insert, make sure nothing's replicated, enable it, the insert should be replicated

Throws:

Exception

testAddAndRemoveClusters

public void testAddAndRemoveClusters()
                              throws Exception

Integration test for TestReplicationAdmin, removes and re-add a peer cluster

Throws:

Exception

testLoading

public void testLoading()
                 throws Exception

Do a more intense version testSmallBatch, one that will trigger wal rolling and other non-trivial code paths

Throws:

Exception

testVerifyListReplicatedTable

public void testVerifyListReplicatedTable()
                                   throws Exception

Test for HBASE-8663

Create two new Tables with colfamilies enabled for replication then run ReplicationAdmin.listReplicated(). Finally verify the table:colfamilies. Note: TestReplicationAdmin is a better place for this testing but it would need mocks.

Throws:

Exception

testReplicationInReplay

public void testReplicationInReplay()
                             throws Exception

Test for HBase-15259 WALEdits under replay will also be replicated

Throws:

Exception

testGetReplicationPeerState

public void testGetReplicationPeerState()
                                 throws Exception

Test for HBASE-27448 Add an admin method to get replication enabled state

Throws:

Exception