Package org.apache.hadoop.hbase.replication

Class SerialReplicationTestBase

java.lang.Object

org.apache.hadoop.hbase.replication.SerialReplicationTestBase

Direct Known Subclasses:

TestAddToSerialReplicationPeer, TestRemoveFromSerialReplicationPeer, TestSerialReplication, TestSerialReplicationFailover

public class SerialReplicationTestBase
extends Object

Base class for testing serial replication.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	SerialReplicationTestBase.LocalReplicationEndpoint

Field Summary

Fields

Modifier and Type	Field	Description
protected static byte[]	CF
protected static byte[]	CQ
protected static org.apache.hadoop.fs.FileSystem	FS
protected static org.apache.hadoop.fs.Path	LOG_DIR
protected org.apache.hadoop.fs.Path	logPath
final org.junit.rules.TestName	name
protected static String	PEER_ID
protected static final HBaseTestingUtility	UTIL
protected static org.apache.hadoop.hbase.wal.WALProvider.Writer	WRITER

Constructor Summary

Constructors

Constructor	Description
SerialReplicationTestBase()

Method Summary

Modifier and Type	Method	Description
protected final void	addPeer(boolean enabled)
protected final void	checkOrder(int expectedEntries)
protected final org.apache.hadoop.hbase.TableName	createTable()
protected final void	enablePeerAndWaitUntilReplicationDone(int expectedEntries)
protected static void	moveRegion(org.apache.hadoop.hbase.client.RegionInfo region, org.apache.hadoop.hbase.regionserver.HRegionServer rs)
protected static void	rollAllWALs()
static void	setUpBeforeClass()
protected final void	setupWALWriter()
void	tearDown()
static void	tearDownAfterClass()
protected final void	waitUntilReplicationDone(int expectedEntries)

Methods inherited from class java.lang.Object

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

Field Details

UTIL

protected static final HBaseTestingUtility UTIL

PEER_ID

protected static String PEER_ID

CF

protected static byte[] CF

CQ

protected static byte[] CQ

FS

protected static org.apache.hadoop.fs.FileSystem FS

LOG_DIR

protected static org.apache.hadoop.fs.Path LOG_DIR

WRITER

protected static org.apache.hadoop.hbase.wal.WALProvider.Writer WRITER

name

public final org.junit.rules.TestName name

logPath

protected org.apache.hadoop.fs.Path logPath

Constructor Details

SerialReplicationTestBase

public SerialReplicationTestBase()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

moveRegion

protected static void moveRegion(org.apache.hadoop.hbase.client.RegionInfo region,
 org.apache.hadoop.hbase.regionserver.HRegionServer rs)
                          throws Exception

Throws:

Exception

rollAllWALs

protected static void rollAllWALs()
                           throws Exception

Throws:

Exception

setupWALWriter

protected final void setupWALWriter()
                             throws IOException

Throws:

IOException

waitUntilReplicationDone

protected final void waitUntilReplicationDone(int expectedEntries)
                                       throws Exception

Throws:

Exception

enablePeerAndWaitUntilReplicationDone

protected final void enablePeerAndWaitUntilReplicationDone(int expectedEntries)
                                                    throws Exception

Throws:

Exception

addPeer

protected final void addPeer(boolean enabled)
                      throws IOException

Throws:

IOException

checkOrder

protected final void checkOrder(int expectedEntries)
                         throws IOException

Throws:

IOException

createTable

protected final org.apache.hadoop.hbase.TableName createTable()
                                                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException