Class TestBulkLoadReplicationHFileRefs
java.lang.Object
org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
org.apache.hadoop.hbase.replication.TestBulkLoadReplicationHFileRefs
@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestBulkLoadReplicationHFileRefs
extends TestReplicationBaseNoBeforeAll
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
TestReplicationBaseNoBeforeAll.ReplicationEndpointTest -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static org.apache.hadoop.hbase.client.Adminprivate static org.apache.hadoop.hbase.client.Adminprivate static final org.apache.hadoop.fs.Pathprivate static final byte[]private static final byte[]private static final Stringprivate static final org.apache.hadoop.hbase.TableNameprivate static final Stringprivate static final Stringprivate byte[]private static org.apache.hadoop.hbase.replication.ReplicationQueueStorageprivate static final Stringprivate static final org.apache.hadoop.hbase.TableNameprivate byte[]private static Fileprivate byte[]Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
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, SLEEP_TIME, tableName, UTIL1, UTIL2 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidbulkLoadOnCluster(org.apache.hadoop.hbase.TableName tableName, byte[] family) private voidcopyToHdfs(byte[] family, String bulkLoadFilePath, org.apache.hadoop.hdfs.MiniDFSCluster cluster) private StringcreateHFileForFamilies(byte[] family) private voidcreateTableOnClusters(org.apache.hadoop.hbase.TableName tableName, byte[]... cfs) voidsetUp()static voidprotected static voidsetupBulkLoadConfigsForCluster(org.apache.hadoop.conf.Configuration config, String clusterReplicationId) voidteardown()voidvoidvoidMethods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll
addPeer, addPeer, cleanUp, configureClusters, createTable, getClusterKey, isSerialPeer, isSyncPeer, loadData, loadData, removePeer, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, startClusters, stopAllRegionServers, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication
-
Field Details
-
PEER1_CLUSTER_ID
- See Also:
-
PEER2_CLUSTER_ID
- See Also:
-
REPLICATE_NAMESPACE
- See Also:
-
NO_REPLICATE_NAMESPACE
- See Also:
-
REPLICATE_TABLE
-
NO_REPLICATE_TABLE
-
CF_A
-
CF_B
-
row
-
qualifier
-
value
-
BULK_LOAD_BASE_DIR
-
admin1
-
admin2
-
queueStorage
-
sourceDir
-
-
Constructor Details
-
TestBulkLoadReplicationHFileRefs
public TestBulkLoadReplicationHFileRefs()
-
-
Method Details
-
setUpBeforeClass
- Throws:
Exception
-
setupBulkLoadConfigsForCluster
protected static void setupBulkLoadConfigsForCluster(org.apache.hadoop.conf.Configuration config, String clusterReplicationId) throws Exception - Throws:
Exception
-
setUp
- Throws:
Exception
-
teardown
- Throws:
Exception
-
testWhenExcludeCF
- Throws:
Exception
-
testWhenExcludeTable
- Throws:
Exception
-
testWhenExcludeNamespace
- Throws:
Exception
-
bulkLoadOnCluster
protected void bulkLoadOnCluster(org.apache.hadoop.hbase.TableName tableName, byte[] family) throws Exception - Throws:
Exception
-
createHFileForFamilies
- Throws:
IOException
-
copyToHdfs
private void copyToHdfs(byte[] family, String bulkLoadFilePath, org.apache.hadoop.hdfs.MiniDFSCluster cluster) throws Exception - Throws:
Exception
-
createTableOnClusters
private void createTableOnClusters(org.apache.hadoop.hbase.TableName tableName, byte[]... cfs) throws IOException - Throws:
IOException
-