Package org.apache.hadoop.hbase.replication

Class TestReplicationSyncUpToolWithBulkLoadedData

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolBase

org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolWithBulkLoadedData

public class TestReplicationSyncUpToolWithBulkLoadedData
extends TestReplicationSyncUpToolBase

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG

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

conn1, conn2, FAMILY, ht1Source, ht1TargetAtPeer1, ht2Source, ht2TargetAtPeer1, NO_REP_FAMILY, QUALIFIER, t1SyncupSource, t1SyncupTarget, t2SyncupSource, t2SyncupTarget, TN1, TN2, UTIL1, UTIL2

Constructor Summary

Constructors

Constructor	Description
TestReplicationSyncUpToolWithBulkLoadedData()

Method Summary

Modifier and Type	Method	Description
protected void	customizeClusterConf(org.apache.hadoop.conf.Configuration conf)
private void	loadAndReplicateHFiles(boolean verifyReplicationOnSlave, Iterator<String> randomHFileRangeListIterator)
private void	loadAndValidateHFileReplication(String testName, byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table source, byte[][][] hfileRanges, int numOfRows)
private void	loadFromOtherHDFSAndValidateHFileReplication(String testName, byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table source, byte[][][] hfileRanges, int numOfRows)
private void	mimicSyncUpAfterBulkLoad(Iterator<String> randomHFileRangeListIterator)
void	testSyncUpTool()
private void	wait(org.apache.hadoop.hbase.client.Table target, int expectedCount, String msg)

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolBase

restartSourceHBaseCluster, restartTargetHBaseCluster, setUp, setupReplication, shutDownSourceHBaseCluster, shutDownTargetHBaseCluster, syncUp, syncUp, tearDown

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

LOG

private static final org.slf4j.Logger LOG

Constructor Details

TestReplicationSyncUpToolWithBulkLoadedData

public TestReplicationSyncUpToolWithBulkLoadedData()

Method Details

customizeClusterConf

protected void customizeClusterConf(org.apache.hadoop.conf.Configuration conf)

Overrides:

customizeClusterConf in class TestReplicationSyncUpToolBase

testSyncUpTool

public void testSyncUpTool()
                    throws Exception

Throws:

Exception

mimicSyncUpAfterBulkLoad

private void mimicSyncUpAfterBulkLoad(Iterator<String> randomHFileRangeListIterator)
                               throws Exception

Throws:

Exception

loadAndReplicateHFiles

private void loadAndReplicateHFiles(boolean verifyReplicationOnSlave,
 Iterator<String> randomHFileRangeListIterator)
                             throws Exception

Throws:

Exception

loadAndValidateHFileReplication

private void loadAndValidateHFileReplication(String testName,
 byte[] row,
 byte[] fam,
 org.apache.hadoop.hbase.client.Table source,
 byte[][][] hfileRanges,
 int numOfRows)
                                      throws Exception

Throws:

Exception

loadFromOtherHDFSAndValidateHFileReplication

private void loadFromOtherHDFSAndValidateHFileReplication(String testName,
 byte[] row,
 byte[] fam,
 org.apache.hadoop.hbase.client.Table source,
 byte[][][] hfileRanges,
 int numOfRows)
                                                   throws Exception

Throws:

Exception

wait

private void wait(org.apache.hadoop.hbase.client.Table target,
 int expectedCount,
 String msg)
           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException