org.apache.hadoop.hbase.replication

Class TestReplicationBase

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

Direct Known Subclasses:

TestBulkLoadReplication, TestBulkLoadReplicationHFileRefs, TestClaimReplicationQueue, TestNamespaceReplication, TestRefreshPeerWhileRegionServerRestarts, TestRefreshRecoveredReplication, TestReplicationAdminWithClusters, TestReplicationChangingPeerRegionservers, TestReplicationCompressedWAL, TestReplicationDisableInactivePeer, TestReplicationDroppedTables, TestReplicationEmptyWALRecovery, TestReplicationEndpoint, TestReplicationKillRS, TestReplicationMetricsforUI, TestReplicationSmallTests, TestReplicationSourceManagerJoin, TestReplicationStatus, TestReplicationStatusAfterLagging, TestReplicationStatusBothNormalAndRecoveryLagging, TestReplicationStatusSink, TestReplicationStatusSourceStartedTargetStoppedNewOp, TestReplicationStatusSourceStartedTargetStoppedNoOps, TestReplicationStatusSourceStartedTargetStoppedWithRecovery, TestReplicationValueCompressedWAL, TestReplicator, TestVerifyReplication, TestVerifyReplicationAdjunct

public class TestReplicationBase
extends Object

This class is only a base for other integration-level replication tests. Do not add tests here. TestReplicationSmallTests is where tests that don't require bring machines up/down should go All other tests should have their own classes and extend this one

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestReplicationBase.ReplicationEndpointTest Custom replication endpoint to keep track of replication status for tests.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.hadoop.hbase.client.replication.ReplicationAdmin	admin
protected static org.apache.hadoop.conf.Configuration	CONF_WITH_LOCALFS
protected static org.apache.hadoop.conf.Configuration	CONF1
protected static org.apache.hadoop.conf.Configuration	CONF2
protected static org.apache.hadoop.hbase.client.Connection	connection1
protected static org.apache.hadoop.hbase.client.Connection	connection2
protected static byte[]	famName
protected static org.apache.hadoop.hbase.client.Admin	hbaseAdmin
protected static org.apache.hadoop.hbase.client.Table	htable1
protected static org.apache.hadoop.hbase.client.Table	htable2
private static org.slf4j.Logger	LOG
protected static int	NB_RETRIES
protected static int	NB_ROWS_IN_BATCH
protected static int	NB_ROWS_IN_BIG_BATCH
protected static byte[]	noRepfamName
protected static int	NUM_SLAVES1
protected static int	NUM_SLAVES2
protected static String	PEER_ID2
protected static AtomicInteger	replicateCount
protected static List<org.apache.hadoop.hbase.wal.WAL.Entry>	replicatedEntries
protected static byte[]	row
protected static long	SLEEP_TIME
protected static org.apache.hadoop.hbase.TableName	tableName
protected static HBaseTestingUtility	UTIL1
protected static HBaseTestingUtility	UTIL2

Constructor Summary

Constructors

Constructor and Description
TestReplicationBase()

Method Summary

Modifier and Type	Method and Description
protected void	addPeer(String peerId, org.apache.hadoop.hbase.TableName tableName)
protected void	cleanUp()
(package private) static void	configureClusters(HBaseTestingUtility util1, HBaseTestingUtility util2)
protected static void	createTable(org.apache.hadoop.hbase.TableName tableName)
protected boolean	isSerialPeer()
protected static void	loadData(String prefix, byte[] row)
protected static void	loadData(String prefix, byte[] row, byte[] familyName)
private boolean	peerExist(String peerId)
protected void	removePeer(String peerId)
(package private) static void	restartSourceCluster(int numSlaves)
(package private) static void	restartTargetHBaseCluster(int numSlaves)
protected static void	runSimplePutDeleteTest()
protected static void	runSmallBatchTest()
void	setUpBase()
static void	setUpBeforeClass()
protected static void	setupConfig(HBaseTestingUtility util, String znodeParent)
private static void	startClusters()
static void	tearDownAfterClass()
void	tearDownBase()
protected static void	waitForReplication(int expectedRows, int retries)
protected static void	waitForReplication(org.apache.hadoop.hbase.client.Table table, int expectedRows, int retries)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

connection1

protected static org.apache.hadoop.hbase.client.Connection connection1

connection2

protected static org.apache.hadoop.hbase.client.Connection connection2

CONF_WITH_LOCALFS

protected static org.apache.hadoop.conf.Configuration CONF_WITH_LOCALFS

admin

protected static org.apache.hadoop.hbase.client.replication.ReplicationAdmin admin

hbaseAdmin

protected static org.apache.hadoop.hbase.client.Admin hbaseAdmin

htable1

protected static org.apache.hadoop.hbase.client.Table htable1

htable2

protected static org.apache.hadoop.hbase.client.Table htable2

UTIL1

protected static final HBaseTestingUtility UTIL1

UTIL2

protected static final HBaseTestingUtility UTIL2

CONF1

protected static org.apache.hadoop.conf.Configuration CONF1

CONF2

protected static org.apache.hadoop.conf.Configuration CONF2

NUM_SLAVES1

protected static int NUM_SLAVES1

NUM_SLAVES2

protected static int NUM_SLAVES2

NB_ROWS_IN_BATCH

protected static final int NB_ROWS_IN_BATCH

See Also:

Constant Field Values

NB_ROWS_IN_BIG_BATCH

protected static final int NB_ROWS_IN_BIG_BATCH

See Also:

Constant Field Values

SLEEP_TIME

protected static final long SLEEP_TIME

See Also:

Constant Field Values

NB_RETRIES

protected static final int NB_RETRIES

See Also:

Constant Field Values

replicateCount

protected static AtomicInteger replicateCount

replicatedEntries

protected static volatile List<org.apache.hadoop.hbase.wal.WAL.Entry> replicatedEntries

tableName

protected static final org.apache.hadoop.hbase.TableName tableName

famName

protected static final byte[] famName

row

protected static final byte[] row

noRepfamName

protected static final byte[] noRepfamName

PEER_ID2

protected static final String PEER_ID2

See Also:

Constant Field Values

Constructor Detail

TestReplicationBase

public TestReplicationBase()

Method Detail

isSerialPeer

protected boolean isSerialPeer()

cleanUp

protected final void cleanUp()
                      throws IOException,
                             InterruptedException

Throws:

IOException

InterruptedException

waitForReplication

protected static void waitForReplication(int expectedRows,
                                         int retries)
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

waitForReplication

protected static void waitForReplication(org.apache.hadoop.hbase.client.Table table,
                                         int expectedRows,
                                         int retries)
                                  throws IOException,
                                         InterruptedException

Throws:

IOException

InterruptedException

loadData

protected static void loadData(String prefix,
                               byte[] row)
                        throws IOException

Throws:

IOException

loadData

protected static void loadData(String prefix,
                               byte[] row,
                               byte[] familyName)
                        throws IOException

Throws:

IOException

setupConfig

protected static void setupConfig(HBaseTestingUtility util,
                                  String znodeParent)

configureClusters

static void configureClusters(HBaseTestingUtility util1,
                              HBaseTestingUtility util2)

restartSourceCluster

static void restartSourceCluster(int numSlaves)
                          throws Exception

Throws:

Exception

restartTargetHBaseCluster

static void restartTargetHBaseCluster(int numSlaves)
                               throws Exception

Throws:

Exception

createTable

protected static void createTable(org.apache.hadoop.hbase.TableName tableName)
                           throws IOException

Throws:

IOException

startClusters

private static void startClusters()
                           throws Exception

Throws:

Exception

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

peerExist

private boolean peerExist(String peerId)
                   throws IOException

Throws:

IOException

addPeer

protected final void addPeer(String peerId,
                             org.apache.hadoop.hbase.TableName tableName)
                      throws Exception

Throws:

Exception

setUpBase

public void setUpBase()
               throws Exception

Throws:

Exception

removePeer

protected final void removePeer(String peerId)
                         throws Exception

Throws:

Exception

tearDownBase

public void tearDownBase()
                  throws Exception

Throws:

Exception

runSimplePutDeleteTest

protected static void runSimplePutDeleteTest()
                                      throws IOException,
                                             InterruptedException

Throws:

IOException

InterruptedException

runSmallBatchTest

protected static void runSmallBatchTest()
                                 throws IOException,
                                        InterruptedException

Throws:

IOException

InterruptedException

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception