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 and Description
static HBaseClassTestRule	CLASS_RULE
private static 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 and Description
TestReplicationSyncUpToolWithBulkLoadedData()

Method Summary

Modifier and Type	Method and 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	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, tearDown

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

TestReplicationSyncUpToolWithBulkLoadedData

public TestReplicationSyncUpToolWithBulkLoadedData()

Method Detail

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

wait

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

Throws:

IOException

InterruptedException