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 and Description
static class	SerialReplicationTestBase.LocalReplicationEndpoint

Field Summary

Fields

Modifier and Type	Field and 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
org.junit.rules.TestName	name
protected static String	PEER_ID
protected static HBaseTestingUtility	UTIL
protected static org.apache.hadoop.hbase.wal.WALProvider.Writer	WRITER

Constructor Summary

Constructors

Constructor and Description
SerialReplicationTestBase()

Method Summary

Modifier and Type	Method and Description
protected void	addPeer(boolean enabled)
protected void	checkOrder(int expectedEntries)
protected org.apache.hadoop.hbase.TableName	createTable()
protected 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 void	setupWALWriter()
void	tearDown()
static void	tearDownAfterClass()
protected void	waitUntilReplicationDone(int expectedEntries)

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

SerialReplicationTestBase

public SerialReplicationTestBase()

Method Detail

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