Class TestReplicationBaseNoBeforeAll
java.lang.Object
org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
- Direct Known Subclasses:
TestRefreshRecoveredReplication,TestReplicationBase,TestReplicationCompressedWAL,TestReplicationSourceManagerJoin,TestReplicationValueCompressedWAL,TestReplicator
Replication test base class without BeforeAll method, as in some tests we need to do some changes
before starting clusters.
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classCustom replication endpoint to keep track of replication status for tests. -
Field Summary
FieldsModifier and TypeFieldDescriptionprotected static org.apache.hadoop.conf.Configurationprotected static org.apache.hadoop.conf.Configurationprotected static org.apache.hadoop.conf.Configurationprotected static org.apache.hadoop.hbase.client.Connectionprotected static org.apache.hadoop.hbase.client.Connectionprotected static final byte[]protected static org.apache.hadoop.hbase.client.Adminprotected static org.apache.hadoop.hbase.client.Tableprotected static org.apache.hadoop.hbase.client.Tableprivate static final org.slf4j.Loggerprotected static final intprotected static final intprotected static final intprotected static final byte[]protected static intprotected static intprotected static final Stringprotected static AtomicIntegerprotected static List<org.apache.hadoop.hbase.wal.WAL.Entry>protected static final byte[]protected static final longprotected static final org.apache.hadoop.hbase.TableNameprotected static final HBaseTestingUtilprotected static final HBaseTestingUtil -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final voidprotected final voidaddPeer(String peerId, org.apache.hadoop.hbase.TableName tableName, HBaseTestingUtil source, HBaseTestingUtil target) protected final voidcleanUp()protected static voidconfigureClusters(HBaseTestingUtil util1, HBaseTestingUtil util2) protected static voidcreateTable(org.apache.hadoop.hbase.TableName tableName) protected Stringprotected booleanprotected booleanprotected static voidprotected static voidprivate booleanpeerExist(String peerId, HBaseTestingUtil util) protected final voidremovePeer(String peerId) protected final voidremovePeer(String peerId, HBaseTestingUtil util) protected static voidrestartSourceCluster(int numSlaves) (package private) static voidrestartTargetHBaseCluster(int numSlaves) protected static voidprotected static voidvoidprotected static voidsetupConfig(HBaseTestingUtil util, String znodeParent) protected static voidprotected static voidstatic voidvoidprotected static voidwaitForReplication(int expectedRows, int retries) protected static voidwaitForReplication(org.apache.hadoop.hbase.client.Table table, int expectedRows, int retries)
-
Field Details
-
LOG
-
connection1
-
connection2
-
CONF_WITH_LOCALFS
-
hbaseAdmin
-
htable1
-
htable2
-
UTIL1
-
UTIL2
-
CONF1
-
CONF2
-
NUM_SLAVES1
-
NUM_SLAVES2
-
NB_ROWS_IN_BATCH
- See Also:
-
NB_ROWS_IN_BIG_BATCH
- See Also:
-
SLEEP_TIME
- See Also:
-
NB_RETRIES
- See Also:
-
replicateCount
-
replicatedEntries
-
tableName
-
famName
-
row
-
noRepfamName
-
PEER_ID2
- See Also:
-
-
Constructor Details
-
TestReplicationBaseNoBeforeAll
public TestReplicationBaseNoBeforeAll()
-
-
Method Details
-
isSerialPeer
-
isSyncPeer
-
cleanUp
- Throws:
IOExceptionInterruptedException
-
waitForReplication
protected static void waitForReplication(int expectedRows, int retries) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-
waitForReplication
protected static void waitForReplication(org.apache.hadoop.hbase.client.Table table, int expectedRows, int retries) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-
loadData
- Throws:
IOException
-
loadData
- Throws:
IOException
-
setupConfig
-
configureClusters
-
restartSourceCluster
- Throws:
Exception
-
restartTargetHBaseCluster
- Throws:
Exception
-
createTable
- Throws:
IOException
-
startClusters
- Throws:
Exception
-
peerExist
- Throws:
IOException
-
getClusterKey
- Throws:
Exception
-
addPeer
protected final void addPeer(String peerId, org.apache.hadoop.hbase.TableName tableName) throws Exception - Throws:
Exception
-
addPeer
protected final void addPeer(String peerId, org.apache.hadoop.hbase.TableName tableName, HBaseTestingUtil source, HBaseTestingUtil target) throws Exception - Throws:
Exception
-
setUpBase
- Throws:
Exception
-
removePeer
- Throws:
Exception
-
removePeer
- Throws:
Exception
-
tearDownBase
- Throws:
Exception
-
runSimplePutDeleteTest
- Throws:
IOExceptionInterruptedException
-
runSmallBatchTest
- Throws:
IOExceptionInterruptedException
-
stopAllRegionServers
- Throws:
IOException
-
tearDownAfterClass
- Throws:
Exception
-