Package org.apache.hadoop.hbase.replication

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

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin1
private static org.apache.hadoop.hbase.client.Admin	admin2
private static final org.apache.hadoop.fs.Path	BULK_LOAD_BASE_DIR
private static final byte[]	CF_A
private static final byte[]	CF_B
private static final String	NO_REPLICATE_NAMESPACE
private static final org.apache.hadoop.hbase.TableName	NO_REPLICATE_TABLE
private static final String	PEER1_CLUSTER_ID
private static final String	PEER2_CLUSTER_ID
private byte[]	qualifier
private static org.apache.hadoop.hbase.replication.ReplicationQueueStorage	queueStorage
private static final String	REPLICATE_NAMESPACE
private static final org.apache.hadoop.hbase.TableName	REPLICATE_TABLE
private byte[]	row
private static File	sourceDir
private byte[]	value

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

Constructor	Description
TestBulkLoadReplicationHFileRefs()

Method Summary

Modifier and Type	Method	Description
protected void	bulkLoadOnCluster(org.apache.hadoop.hbase.TableName tableName, byte[] family)
private void	copyToHdfs(byte[] family, String bulkLoadFilePath, org.apache.hadoop.hdfs.MiniDFSCluster cluster)
private String	createHFileForFamilies(byte[] family)
private void	createTableOnClusters(org.apache.hadoop.hbase.TableName tableName, byte[]... cfs)
void	setUp()
static void	setUpBeforeClass()
protected static void	setupBulkLoadConfigsForCluster(org.apache.hadoop.conf.Configuration config, String clusterReplicationId)
void	teardown()
void	testWhenExcludeCF()
void	testWhenExcludeNamespace()
void	testWhenExcludeTable()

Methods 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PEER1_CLUSTER_ID

private static final String PEER1_CLUSTER_ID

See Also:

• Constant Field Values

PEER2_CLUSTER_ID

private static final String PEER2_CLUSTER_ID

See Also:

• Constant Field Values

REPLICATE_NAMESPACE

private static final String REPLICATE_NAMESPACE

See Also:

• Constant Field Values

NO_REPLICATE_NAMESPACE

private static final String NO_REPLICATE_NAMESPACE

See Also:

• Constant Field Values

REPLICATE_TABLE

private static final org.apache.hadoop.hbase.TableName REPLICATE_TABLE

NO_REPLICATE_TABLE

private static final org.apache.hadoop.hbase.TableName NO_REPLICATE_TABLE

CF_A

private static final byte[] CF_A

CF_B

private static final byte[] CF_B

row

private byte[] row

qualifier

private byte[] qualifier

value

private byte[] value

BULK_LOAD_BASE_DIR

private static final org.apache.hadoop.fs.Path BULK_LOAD_BASE_DIR

admin1

private static org.apache.hadoop.hbase.client.Admin admin1

admin2

private static org.apache.hadoop.hbase.client.Admin admin2

queueStorage

private static org.apache.hadoop.hbase.replication.ReplicationQueueStorage queueStorage

sourceDir

private static File sourceDir

Constructor Details

TestBulkLoadReplicationHFileRefs

public TestBulkLoadReplicationHFileRefs()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

setupBulkLoadConfigsForCluster

protected static void setupBulkLoadConfigsForCluster(org.apache.hadoop.conf.Configuration config,
 String clusterReplicationId)
                                              throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

teardown

@AfterEach
public void teardown()
              throws Exception

Throws:

Exception

testWhenExcludeCF

@Test
public void testWhenExcludeCF()
                       throws Exception

Throws:

Exception

testWhenExcludeTable

@Test
public void testWhenExcludeTable()
                          throws Exception

Throws:

Exception

testWhenExcludeNamespace

@Test
public void testWhenExcludeNamespace()
                              throws Exception

Throws:

Exception

bulkLoadOnCluster

protected void bulkLoadOnCluster(org.apache.hadoop.hbase.TableName tableName,
 byte[] family)
                          throws Exception

Throws:

Exception

createHFileForFamilies

private String createHFileForFamilies(byte[] family)
                               throws IOException

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