org.apache.hadoop.hbase.replication

Class TestReplicationEndpoint

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationEndpoint

Direct Known Subclasses:

TestReplicationEndpointWithMultipleAsyncWAL, TestReplicationEndpointWithMultipleWAL

public class TestReplicationEndpoint
extends TestReplicationBase

Tests ReplicationSource and ReplicationEndpoint interactions

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
(package private) static int	numRegionServers

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

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

Constructor Summary

Constructors

Constructor and Description
TestReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
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()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCustomReplicationEndpoint()
void	testInterClusterReplication()
void	testMetricsSourceBaseSourcePassThrough()
void	testReplicationEndpointReturnsFalseOnReplicate()
void	testWALEntryFilterAddValidation()
void	testWALEntryFilterFromReplicationEndpoint()
void	testWALEntryFilterUpdateValidation()

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

cleanUp, configureClusters, isSerialPeer, loadData, loadData, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, tearDownBase, waitForReplication, waitForReplication

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

numRegionServers

static int numRegionServers

Constructor Detail

TestReplicationEndpoint

public TestReplicationEndpoint()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setup

public void setup()
           throws Exception

Throws:

Exception

testCustomReplicationEndpoint

public void testCustomReplicationEndpoint()
                                   throws Exception

Throws:

Exception

testReplicationEndpointReturnsFalseOnReplicate

public void testReplicationEndpointReturnsFalseOnReplicate()
                                                    throws Exception

Throws:

Exception

testInterClusterReplication

public void testInterClusterReplication()
                                 throws Exception

Throws:

Exception

testWALEntryFilterFromReplicationEndpoint

public void testWALEntryFilterFromReplicationEndpoint()
                                               throws Exception

Throws:

Exception

testWALEntryFilterAddValidation

public void testWALEntryFilterAddValidation()
                                     throws Exception

Throws:

Exception

testWALEntryFilterUpdateValidation

public void testWALEntryFilterUpdateValidation()
                                        throws Exception

Throws:

Exception

testMetricsSourceBaseSourcePassThrough

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