org.apache.hadoop.hbase.replication

Class TestReplicationSyncUpToolWithBulkLoadedData

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationSyncUpTool

org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolWithBulkLoadedData

public class TestReplicationSyncUpToolWithBulkLoadedData
extends TestReplicationSyncUpTool

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.TestReplicationSyncUpTool

famName, ht1Source, ht1TargetAtPeer1, ht2Source, ht2TargetAtPeer1, noRepfamName

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

admin, CONF_WITH_LOCALFS, conf1, conf2, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, row, scopes, seperateOldWALs, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2

Constructor Summary

Constructors

Constructor and Description
TestReplicationSyncUpToolWithBulkLoadedData()

Method Summary

Modifier and Type	Method and Description
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)
static void	setUpBeforeClass()
void	testSyncUpTool() Add a row to a table in each cluster, check it's replicated, delete it, check's gone Also check the puts and deletes are not replicated back to the originating cluster.
private void	wait(org.apache.hadoop.hbase.client.Table target, int expectedCount, String msg)

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

setUp, setupReplication, syncUp

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

cleanUp, loadData, params, runSimplePutDeleteTest, runSmallBatchTest, tearDownAfterClass, waitForReplication

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

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

testSyncUpTool

public void testSyncUpTool()
                    throws Exception

Description copied from class: TestReplicationSyncUpTool

Add a row to a table in each cluster, check it's replicated, delete it, check's gone Also check the puts and deletes are not replicated back to the originating cluster.

Overrides:

testSyncUpTool in class TestReplicationSyncUpTool

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