Package org.apache.hadoop.hbase.replication

Class ReplicationEndpointTestBase

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll

org.apache.hadoop.hbase.replication.ReplicationEndpointTestBase

Direct Known Subclasses:

TestReplicationEndpoint, TestReplicationEndpointWithMultipleAsyncWAL, TestReplicationEndpointWithMultipleWAL

public class ReplicationEndpointTestBase
extends TestReplicationBaseNoBeforeAll

Tests ReplicationSource and ReplicationEndpoint interactions

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReplicationEndpointTestBase.EverythingPassesWALEntryFilter
static class	ReplicationEndpointTestBase.EverythingPassesWALEntryFilterSubclass
static class	ReplicationEndpointTestBase.InterClusterReplicationEndpointForTest
static class	ReplicationEndpointTestBase.ReplicationEndpointForTest
static class	ReplicationEndpointTestBase.ReplicationEndpointReturningFalse
static class	ReplicationEndpointTestBase.ReplicationEndpointWithWALEntryFilter
static class	ReplicationEndpointTestBase.SleepingReplicationEndpointForTest	Not used by unit tests, helpful for manual testing with replication.

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
(package private) static int	numRegionServers

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
ReplicationEndpointTestBase()

Method Summary

Modifier and Type	Method	Description
static void	assertStopped()
private org.apache.hadoop.hbase.wal.WAL.Entry	createEntry(String tableName, TreeMap<byte[],Integer> scopes, byte[]... kvs)
private List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.wal.WAL.Entry,Long>>	createWALEntriesWithSize(String tableName)
private static void	doAssert(byte[] row)
private void	doPut(byte[] row)
private void	doPut(org.apache.hadoop.hbase.client.Connection connection, byte[] row)
void	setup()
protected static void	setUpBeforeClass()
void	testCustomReplicationEndpoint()
void	testInterClusterReplication()
void	testMetricsSourceBaseSourcePassThrough()
void	testReplicationEndpointReturnsFalseOnReplicate()
void	testWALEntryFilterAddValidation()
void	testWALEntryFilterFromReplicationEndpoint()
void	testWALEntryFilterUpdateValidation()

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

addPeer, addPeer, cleanUp, configureClusters, createTable, getClusterKey, isSerialPeer, 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

numRegionServers

static int numRegionServers

Constructor Details

ReplicationEndpointTestBase

public ReplicationEndpointTestBase()

Method Details

setUpBeforeClass

protected static void setUpBeforeClass()
                                throws Exception

Throws:

Exception

assertStopped

@AfterAll
public static void assertStopped()

setup

@BeforeEach
public void setup()
           throws Exception

Throws:

Exception

testCustomReplicationEndpoint

@Test
public void testCustomReplicationEndpoint()
                                   throws Exception

Throws:

Exception

testReplicationEndpointReturnsFalseOnReplicate

@Test
public void testReplicationEndpointReturnsFalseOnReplicate()
                                                    throws Exception

Throws:

Exception

testInterClusterReplication

@Test
public void testInterClusterReplication()
                                 throws Exception

Throws:

Exception

testWALEntryFilterFromReplicationEndpoint

@Test
public void testWALEntryFilterFromReplicationEndpoint()
                                               throws Exception

Throws:

Exception

testWALEntryFilterAddValidation

@Test
public void testWALEntryFilterAddValidation()
                                     throws Exception

Throws:

Exception

testWALEntryFilterUpdateValidation

@Test
public void testWALEntryFilterUpdateValidation()
                                        throws Exception

Throws:

Exception

testMetricsSourceBaseSourcePassThrough

@Test
public void testMetricsSourceBaseSourcePassThrough()

createWALEntriesWithSize

private List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.wal.WAL.Entry,Long>> createWALEntriesWithSize(String tableName)

createEntry

private org.apache.hadoop.hbase.wal.WAL.Entry createEntry(String tableName,
 TreeMap<byte[],Integer> scopes,
 byte[]... kvs)

doPut

private void doPut(byte[] row)
            throws IOException

Throws:

IOException

doPut

private void doPut(org.apache.hadoop.hbase.client.Connection connection,
 byte[] row)
            throws IOException

Throws:

IOException

doAssert

private static void doAssert(byte[] row)
                      throws Exception

Throws:

Exception