Package org.apache.hadoop.hbase.replication

Class TestReplicationSmallTests

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationSmallTests

Direct Known Subclasses:

TestReplicationSmallTestsSync

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestReplicationSmallTests
extends TestReplicationBase

Nested Class Summary

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

TestReplicationBaseNoBeforeAll.ReplicationEndpointTest

Field Summary

Fields

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

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

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(boolean serialPeer)

Method Summary

Modifier and Type	Method	Description
protected boolean	isSerialPeer()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
void	setUp()
void	testAddAndRemoveClusters()	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

setUpBeforeClass

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

addPeer, addPeer, cleanUp, configureClusters, createTable, getClusterKey, isSyncPeer, loadData, loadData, removePeer, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, startClusters, stopAllRegionServers, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication

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

PEER_ID

private static final String PEER_ID

See Also:

• Constant Field Values

serialPeer

private boolean serialPeer

Constructor Details

TestReplicationSmallTests

public TestReplicationSmallTests(boolean serialPeer)

Method Details

isSerialPeer

protected boolean isSerialPeer()

Overrides:

isSerialPeer in class TestReplicationBaseNoBeforeAll

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

testDeleteTypes

@TestTemplate
public void testDeleteTypes()
                     throws Exception

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

Throws:

Exception

testSimplePutDelete

@TestTemplate
public void testSimplePutDelete()
                         throws Exception

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

Throws:

Exception

testSmallBatch

@TestTemplate
public void testSmallBatch()
                    throws Exception

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

Throws:

Exception

testDisableEnable

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

@TestTemplate
public void testAddAndRemoveClusters()
                              throws Exception

Removes and re-add a peer cluster

Throws:

Exception

testLoading

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

@TestTemplate
public void testVerifyListReplicatedTable()
                                   throws Exception

Test for HBASE-8663

Create two new Tables with colfamilies enabled for replication then run Admin.listReplicatedTableCFs(). Finally verify the table:colfamilies.

Throws:

Exception

testReplicationInReplay

@TestTemplate
public void testReplicationInReplay()
                             throws Exception

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

Throws:

Exception

testGetReplicationPeerState

@TestTemplate
public void testGetReplicationPeerState()
                                 throws Exception

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

Throws:

Exception