Package org.apache.hadoop.hbase.replication

Class TestReplicationSyncUpToolWithBulkLoadedData

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolBase

org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolWithBulkLoadedData

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestReplicationSyncUpToolWithBulkLoadedData
extends TestReplicationSyncUpToolBase

Field Summary

Fields

Modifier and Type	Field	Description
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

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

@Test
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