public class SyncReplicationTestBase extends Object
Modifier and Type | Field and Description |
---|---|
protected static byte[] |
CF |
protected static byte[] |
CQ |
protected static String |
PEER_ID |
protected static org.apache.hadoop.fs.Path |
REMOTE_WAL_DIR1 |
protected static org.apache.hadoop.fs.Path |
REMOTE_WAL_DIR2 |
protected static org.apache.hadoop.hbase.TableName |
TABLE_NAME |
protected static HBaseTestingUtil |
UTIL1 |
protected static HBaseTestingUtil |
UTIL2 |
protected static HBaseZKTestingUtil |
ZK_UTIL |
Constructor and Description |
---|
SyncReplicationTestBase() |
Modifier and Type | Method and Description |
---|---|
private void |
assertRejection(Throwable error) |
protected org.apache.hadoop.fs.Path |
getRemoteWALDir(org.apache.hadoop.hbase.master.MasterFileSystem mfs,
String peerId) |
protected org.apache.hadoop.fs.Path |
getRemoteWALDir(org.apache.hadoop.fs.Path remoteWALDir,
String peerId) |
protected org.apache.hadoop.fs.Path |
getReplayRemoteWALs(org.apache.hadoop.fs.Path remoteWALDir,
String peerId) |
protected static void |
initTestingUtility(HBaseTestingUtil util,
String zkParent) |
static void |
setUp() |
private static void |
shutdown(HBaseTestingUtil util) |
static void |
tearDown() |
protected void |
verify(HBaseTestingUtil util,
int start,
int end) |
protected void |
verifyNotReplicatedThroughRegion(HBaseTestingUtil util,
int start,
int end) |
protected void |
verifyRemovedPeer(String peerId,
org.apache.hadoop.fs.Path remoteWALDir,
HBaseTestingUtil utility) |
protected void |
verifyReplicationRequestRejection(HBaseTestingUtil utility,
boolean expectedRejection) |
protected void |
verifyThroughRegion(HBaseTestingUtil util,
int start,
int end) |
protected void |
waitUntilDeleted(HBaseTestingUtil util,
org.apache.hadoop.fs.Path remoteWAL) |
protected void |
waitUntilReplicationDone(HBaseTestingUtil util,
int end) |
protected void |
write(HBaseTestingUtil util,
int start,
int end) |
protected void |
writeAndVerifyReplication(HBaseTestingUtil util1,
HBaseTestingUtil util2,
int start,
int end) |
protected static final HBaseZKTestingUtil ZK_UTIL
protected static final HBaseTestingUtil UTIL1
protected static final HBaseTestingUtil UTIL2
protected static org.apache.hadoop.hbase.TableName TABLE_NAME
protected static byte[] CF
protected static byte[] CQ
protected static org.apache.hadoop.fs.Path REMOTE_WAL_DIR1
protected static org.apache.hadoop.fs.Path REMOTE_WAL_DIR2
public SyncReplicationTestBase()
protected static void initTestingUtility(HBaseTestingUtil util, String zkParent)
private static void shutdown(HBaseTestingUtil util) throws Exception
Exception
protected final void write(HBaseTestingUtil util, int start, int end) throws IOException
IOException
protected final void verify(HBaseTestingUtil util, int start, int end) throws IOException
IOException
protected final void verifyThroughRegion(HBaseTestingUtil util, int start, int end) throws IOException
IOException
protected final void verifyNotReplicatedThroughRegion(HBaseTestingUtil util, int start, int end) throws IOException
IOException
protected final void waitUntilReplicationDone(HBaseTestingUtil util, int end) throws Exception
Exception
protected final void writeAndVerifyReplication(HBaseTestingUtil util1, HBaseTestingUtil util2, int start, int end) throws Exception
Exception
protected final org.apache.hadoop.fs.Path getRemoteWALDir(org.apache.hadoop.hbase.master.MasterFileSystem mfs, String peerId)
protected final org.apache.hadoop.fs.Path getRemoteWALDir(org.apache.hadoop.fs.Path remoteWALDir, String peerId)
protected final org.apache.hadoop.fs.Path getReplayRemoteWALs(org.apache.hadoop.fs.Path remoteWALDir, String peerId)
protected final void verifyRemovedPeer(String peerId, org.apache.hadoop.fs.Path remoteWALDir, HBaseTestingUtil utility) throws Exception
Exception
private void assertRejection(Throwable error)
protected final void verifyReplicationRequestRejection(HBaseTestingUtil utility, boolean expectedRejection) throws Exception
Exception
protected final void waitUntilDeleted(HBaseTestingUtil util, org.apache.hadoop.fs.Path remoteWAL) throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.