public class TestRecoverStandbyProcedure extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
conf |
private static byte[] |
family |
private static org.apache.hadoop.fs.FileSystem |
fs |
private static org.slf4j.Logger |
LOG |
private static String |
PEER_ID |
private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> |
procExec |
private static byte[] |
qualifier |
private static org.apache.hadoop.hbase.client.RegionInfo |
regionInfo |
private static int |
ROW_COUNT |
private static int |
RS_NUMBER |
private static org.apache.hadoop.hbase.master.replication.SyncReplicationReplayWALManager |
syncReplicationReplayWALManager |
private static org.apache.hadoop.hbase.TableName |
tableName |
private static long |
timestamp |
private static HBaseTestingUtil |
UTIL |
private static int |
WAL_NUMBER |
Constructor and Description |
---|
TestRecoverStandbyProcedure() |
Modifier and Type | Method and 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() |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final org.apache.hadoop.hbase.TableName tableName
private static final org.apache.hadoop.hbase.client.RegionInfo regionInfo
private static final byte[] family
private static final byte[] qualifier
private static final long timestamp
private static final int ROW_COUNT
private static final int WAL_NUMBER
private static final int RS_NUMBER
private static final String PEER_ID
private static final HBaseTestingUtil UTIL
private static org.apache.hadoop.hbase.master.replication.SyncReplicationReplayWALManager syncReplicationReplayWALManager
private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> procExec
private static org.apache.hadoop.fs.FileSystem fs
private static org.apache.hadoop.conf.Configuration conf
public TestRecoverStandbyProcedure()
public static void setupCluster() throws Exception
Exception
public static void cleanupTest() throws Exception
Exception
public void setupBeforeTest() throws IOException
IOException
public void tearDownAfterTest() throws IOException
IOException
public void testRecoverStandby() throws IOException, org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException
IOException
org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException
private void setupSyncReplicationWALs() throws IOException, org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException
IOException
org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException
private List<org.apache.hadoop.hbase.wal.WAL.Entry> setupWALEntries(int startRow, int endRow)
private org.apache.hadoop.hbase.wal.WAL.Entry createWALEntry(byte[] row, byte[] value)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.