org.apache.hadoop.hbase.replication

Class TestReplicationSyncUpTool

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationSyncUpTool

Direct Known Subclasses:

TestReplicationSyncUpToolWithBulkLoadedData

public class TestReplicationSyncUpTool
extends TestReplicationBase

Field Summary

Fields

Modifier and Type	Field and Description
protected static byte[]	famName
protected Table	ht1Source
protected Table	ht1TargetAtPeer1
protected Table	ht2Source
protected Table	ht2TargetAtPeer1
protected static byte[]	noRepfamName

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

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

Constructor Summary

Constructors

Constructor and Description
TestReplicationSyncUpTool()

Method Summary

Modifier and Type	Method and Description
void	setUp()
protected void	setupReplication()
protected void	syncUp(HBaseTestingUtility ut)
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.

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

setUpBeforeClass, tearDownAfterClass

Methods inherited from class java.lang.Object

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

Field Detail

famName

protected static final byte[] famName

noRepfamName

protected static final byte[] noRepfamName

ht1Source

protected Table ht1Source

ht2Source

protected Table ht2Source

ht1TargetAtPeer1

protected Table ht1TargetAtPeer1

ht2TargetAtPeer1

protected Table ht2TargetAtPeer1

Constructor Detail

TestReplicationSyncUpTool

public TestReplicationSyncUpTool()

Method Detail

setUp

public void setUp()
           throws java.lang.Exception

Throws:

java.lang.Exception

testSyncUpTool

public void testSyncUpTool()
                    throws java.lang.Exception

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.

Throws:

java.lang.Exception

setupReplication

protected void setupReplication()
                         throws java.lang.Exception

Throws:

java.lang.Exception

syncUp

protected void syncUp(HBaseTestingUtility ut)
               throws java.lang.Exception

Throws:

java.lang.Exception