org.apache.hadoop.hbase.replication

Class TestReplicationBase

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

Direct Known Subclasses:

TestNamespaceReplication, TestReplicationAdminWithClusters, TestReplicationChangingPeerRegionservers, TestReplicationDisableInactivePeer, TestReplicationDroppedTables, TestReplicationEmptyWALRecovery, TestReplicationEndpoint, TestReplicationKillRS, TestReplicationSmallTests, TestReplicationStatus, TestReplicationSyncUpTool, TestReplicator, TestVerifyReplication

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

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 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 byte[]	row
protected static NavigableMap<byte[],Integer>	scopes
static boolean	seperateOldWALs
protected static long	SLEEP_TIME
protected static org.apache.hadoop.hbase.TableName	tableName
protected static HBaseTestingUtility	utility1
protected static HBaseTestingUtility	utility2
protected static org.apache.hadoop.hbase.zookeeper.ZKWatcher	zkw1
protected static org.apache.hadoop.hbase.zookeeper.ZKWatcher	zkw2

Constructor Summary

Constructors

Constructor and Description
TestReplicationBase()

Method Summary

Modifier and Type	Method and Description
protected void	cleanUp()
protected static void	loadData(String prefix, byte[] row)
static List<Boolean>	params()
protected static void	runSimplePutDeleteTest()
protected static void	runSmallBatchTest()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
protected static void	waitForReplication(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

conf1

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

conf2

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

CONF_WITH_LOCALFS

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

zkw1

protected static org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw1

zkw2

protected static org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw2

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

scopes

protected static NavigableMap<byte[],Integer> scopes

utility1

protected static HBaseTestingUtility utility1

utility2

protected static HBaseTestingUtility utility2

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

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

seperateOldWALs

public static boolean seperateOldWALs

Constructor Detail

TestReplicationBase

public TestReplicationBase()

Method Detail

params

public static List<Boolean> params()

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

loadData

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

Throws:

IOException

setUpBeforeClass

public static void setUpBeforeClass()
                             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