Package org.apache.hadoop.hbase.replication.master

Class TestRecoverStandbyProcedure

java.lang.Object

org.apache.hadoop.hbase.replication.master.TestRecoverStandbyProcedure

public class TestRecoverStandbyProcedure
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	conf
private static final byte[]	family
private static org.apache.hadoop.fs.FileSystem	fs
private static final org.slf4j.Logger	LOG
private static final String	PEER_ID
private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	procExec
private static final byte[]	qualifier
private static final org.apache.hadoop.hbase.client.RegionInfo	regionInfo
private static final int	ROW_COUNT
private static final int	RS_NUMBER
private static org.apache.hadoop.hbase.master.replication.SyncReplicationReplayWALManager	syncReplicationReplayWALManager
private static final org.apache.hadoop.hbase.TableName	tableName
private static final long	timestamp
private static final HBaseTestingUtil	UTIL
private static final int	WAL_NUMBER

Constructor Summary

Constructors

Constructor	Description
TestRecoverStandbyProcedure()

Method Summary

Modifier and Type	Method	Description
static void	cleanupTest()
private org.apache.hadoop.hbase.wal.WAL.Entry	createWALEntry(byte[] row, byte[] value)
void	setupBeforeTest()
static void	setupCluster()
private void	setupSyncReplicationWALs()
private List<org.apache.hadoop.hbase.wal.WAL.Entry>	setupWALEntries(int startRow, int endRow)
void	tearDownAfterTest()
void	testRecoverStandby()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

tableName

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

regionInfo

private static final org.apache.hadoop.hbase.client.RegionInfo regionInfo

family

private static final byte[] family

qualifier

private static final byte[] qualifier

timestamp

private static final long timestamp

ROW_COUNT

private static final int ROW_COUNT

See Also:

• Constant Field Values

WAL_NUMBER

private static final int WAL_NUMBER

See Also:

• Constant Field Values

RS_NUMBER

private static final int RS_NUMBER

See Also:

• Constant Field Values

PEER_ID

private static final String PEER_ID

See Also:

• Constant Field Values

UTIL

private static final HBaseTestingUtil UTIL

syncReplicationReplayWALManager

private static org.apache.hadoop.hbase.master.replication.SyncReplicationReplayWALManager syncReplicationReplayWALManager

procExec

private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> procExec

fs

private static org.apache.hadoop.fs.FileSystem fs

conf

private static org.apache.hadoop.conf.Configuration conf

Constructor Details

TestRecoverStandbyProcedure

public TestRecoverStandbyProcedure()

Method Details

setupCluster

public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTest

public static void cleanupTest()
                        throws Exception

Throws:

Exception

setupBeforeTest

public void setupBeforeTest()
                     throws IOException

Throws:

IOException

tearDownAfterTest

public void tearDownAfterTest()
                       throws IOException

Throws:

IOException

testRecoverStandby

public void testRecoverStandby()
                        throws IOException,
org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

Throws:

IOException

org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

setupSyncReplicationWALs

private void setupSyncReplicationWALs()
                               throws IOException,
org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

Throws:

IOException

org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

setupWALEntries

private List<org.apache.hadoop.hbase.wal.WAL.Entry> setupWALEntries(int startRow,
 int endRow)

createWALEntry

private org.apache.hadoop.hbase.wal.WAL.Entry createWALEntry(byte[] row,
 byte[] value)