Package org.apache.hadoop.hbase.regionserver

Class TestBulkLoadReplicationHFileRefs

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.regionserver.TestBulkLoadReplicationHFileRefs

public class TestBulkLoadReplicationHFileRefs
extends TestReplicationBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

TestReplicationBase.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
static final HBaseClassTestRule	CLASS_RULE
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
static org.junit.rules.TemporaryFolder	testFolder
private byte[]	value

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

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, 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.TestReplicationBase

addPeer, cleanUp, createTable, isSerialPeer, loadData, loadData, removePeer, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

testFolder

public static org.junit.rules.TemporaryFolder testFolder

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

Constructor Details

TestBulkLoadReplicationHFileRefs

public TestBulkLoadReplicationHFileRefs()

Method Details

setUpBeforeClass

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

public void setUp()
           throws Exception

Throws:

Exception

teardown

public void teardown()
              throws Exception

Throws:

Exception

testWhenExcludeCF

public void testWhenExcludeCF()
                       throws Exception

Throws:

Exception

testWhenExcludeTable

public void testWhenExcludeTable()
                          throws Exception

Throws:

Exception

testWhenExcludeNamespace

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