public class TestRefreshRecoveredReplication extends TestReplicationBase
TestReplicationBase.ReplicationEndpointTest
Modifier and Type | Field and Description |
---|---|
private static int |
BATCH |
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
org.junit.rules.TestName |
name |
private org.apache.hadoop.hbase.client.Table |
table1 |
private org.apache.hadoop.hbase.client.Table |
table2 |
private org.apache.hadoop.hbase.TableName |
tablename |
admin, CONF_WITH_LOCALFS, CONF1, CONF2, connection1, connection2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, replicateCount, replicatedEntries, row, SLEEP_TIME, tableName, UTIL1, UTIL2
Constructor and Description |
---|
TestRefreshRecoveredReplication() |
Modifier and Type | Method and Description |
---|---|
private int |
checkReplicationData() |
void |
setup() |
static void |
setUpBeforeClass() |
void |
teardown() |
static void |
tearDownAfterClass() |
void |
testReplicationRefreshSource() |
addPeer, cleanUp, createTable, isSerialPeer, loadData, loadData, removePeer, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, tearDownBase, waitForReplication, waitForReplication
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final int BATCH
public org.junit.rules.TestName name
private org.apache.hadoop.hbase.TableName tablename
private org.apache.hadoop.hbase.client.Table table1
private org.apache.hadoop.hbase.client.Table table2
public TestRefreshRecoveredReplication()
public static void setUpBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws Exception
Exception
public void testReplicationRefreshSource() throws Exception
Exception
private int checkReplicationData() throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.