public class TestBulkLoadReplication extends TestReplicationBase
Modifier and Type | Class and Description |
---|---|
static class |
TestBulkLoadReplication.BulkReplicationTestObserver |
Modifier and Type | Field and Description |
---|---|
private static org.apache.hadoop.fs.Path |
BULK_LOAD_BASE_DIR |
private static CountDownLatch |
BULK_LOAD_LATCH |
private static AtomicInteger |
BULK_LOADS_COUNT |
static HBaseClassTestRule |
CLASS_RULE |
private static org.apache.hadoop.conf.Configuration |
conf3 |
private static org.apache.hadoop.conf.Configuration |
conf4 |
private static org.apache.hadoop.hbase.client.Table |
htable3 |
private static org.apache.hadoop.hbase.client.Table |
htable4 |
protected static org.slf4j.Logger |
LOG |
org.junit.rules.TestName |
name |
private static String |
PEER_ID1 |
private static String |
PEER_ID3 |
private static String |
PEER_ID4 |
private static String |
PEER1_CLUSTER_ID |
private static String |
PEER3_CLUSTER_ID |
private static String |
PEER4_CLUSTER_ID |
static org.junit.rules.TemporaryFolder |
testFolder |
private static HBaseTestingUtility |
utility3 |
private static HBaseTestingUtility |
utility4 |
admin, CONF_WITH_LOCALFS, conf1, conf2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, PEER_ID2, row, scopes, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2
Constructor and Description |
---|
TestBulkLoadReplication() |
Modifier and Type | Method and Description |
---|---|
private void |
assertBulkLoadConditions(byte[] row,
byte[] value,
HBaseTestingUtility utility,
org.apache.hadoop.hbase.client.Table... tables) |
private void |
assertTableHasValue(org.apache.hadoop.hbase.client.Table table,
byte[] row,
byte[] value) |
private void |
bulkLoadOnCluster(byte[] row,
byte[] value,
HBaseTestingUtility cluster) |
private void |
copyToHdfs(String bulkLoadFilePath,
org.apache.hadoop.hdfs.MiniDFSCluster cluster) |
private String |
createHFileForFamilies(byte[] row,
byte[] value,
org.apache.hadoop.conf.Configuration clusterConfig) |
private org.apache.hadoop.fs.Path |
createMobFiles(HBaseTestingUtility util) |
private org.apache.hadoop.hbase.replication.ReplicationPeerConfig |
getPeerConfigForCluster(HBaseTestingUtility util) |
void |
setUpBase() |
static void |
setUpBeforeClass() |
private static void |
setupBulkLoadConfigsForCluster(org.apache.hadoop.conf.Configuration config,
String clusterReplicationId) |
private void |
setupCoprocessor(HBaseTestingUtility cluster) |
private static void |
startCluster(HBaseTestingUtility util,
org.apache.hadoop.conf.Configuration configuration) |
void |
tearDownBase() |
void |
testBulkLoadReplicationActiveActive() |
void |
testPartionedMOBCompactionBulkLoadDoesntReplicate() |
cleanUp, isSerialPeer, loadData, loadData, runSimplePutDeleteTest, runSmallBatchTest, tearDownAfterClass, waitForReplication
public static final HBaseClassTestRule CLASS_RULE
protected static final org.slf4j.Logger LOG
private static final String PEER1_CLUSTER_ID
private static final String PEER4_CLUSTER_ID
private static final String PEER3_CLUSTER_ID
private static final String PEER_ID1
private static final String PEER_ID3
private static final String PEER_ID4
private static AtomicInteger BULK_LOADS_COUNT
private static CountDownLatch BULK_LOAD_LATCH
private static final org.apache.hadoop.fs.Path BULK_LOAD_BASE_DIR
private static HBaseTestingUtility utility3
private static HBaseTestingUtility utility4
private static org.apache.hadoop.conf.Configuration conf3
private static org.apache.hadoop.conf.Configuration conf4
private static org.apache.hadoop.hbase.client.Table htable3
private static org.apache.hadoop.hbase.client.Table htable4
public org.junit.rules.TestName name
public static org.junit.rules.TemporaryFolder testFolder
public TestBulkLoadReplication()
public static void setUpBeforeClass() throws Exception
Exception
private static void startCluster(HBaseTestingUtility util, org.apache.hadoop.conf.Configuration configuration) throws Exception
Exception
public void setUpBase() throws Exception
setUpBase
in class TestReplicationBase
Exception
private org.apache.hadoop.hbase.replication.ReplicationPeerConfig getPeerConfigForCluster(HBaseTestingUtility util)
private void setupCoprocessor(HBaseTestingUtility cluster)
public void tearDownBase() throws Exception
tearDownBase
in class TestReplicationBase
Exception
private static void setupBulkLoadConfigsForCluster(org.apache.hadoop.conf.Configuration config, String clusterReplicationId) throws Exception
Exception
public void testBulkLoadReplicationActiveActive() throws Exception
Exception
public void testPartionedMOBCompactionBulkLoadDoesntReplicate() throws Exception
Exception
private void assertBulkLoadConditions(byte[] row, byte[] value, HBaseTestingUtility utility, org.apache.hadoop.hbase.client.Table... tables) throws Exception
Exception
private void bulkLoadOnCluster(byte[] row, byte[] value, HBaseTestingUtility cluster) throws Exception
Exception
private void copyToHdfs(String bulkLoadFilePath, org.apache.hadoop.hdfs.MiniDFSCluster cluster) throws Exception
Exception
private void assertTableHasValue(org.apache.hadoop.hbase.client.Table table, byte[] row, byte[] value) throws Exception
Exception
private String createHFileForFamilies(byte[] row, byte[] value, org.apache.hadoop.conf.Configuration clusterConfig) throws IOException
IOException
private org.apache.hadoop.fs.Path createMobFiles(HBaseTestingUtility util) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.