Package org.apache.hadoop.hbase.replication

Class TestReplicationSyncUpTool

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolBase

org.apache.hadoop.hbase.replication.TestReplicationSyncUpTool

Direct Known Subclasses:

TestReplicationSyncUpToolWithMultipleAsyncWAL, TestReplicationSyncUpToolWithMultipleWAL

public class TestReplicationSyncUpTool
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
TestReplicationSyncUpTool()

Method Summary

Modifier and Type	Method	Description
private void	mimicSyncUpAfterDelete()
private void	mimicSyncUpAfterPut()
private void	putAndReplicateRows()
void	testStartANewSyncUpToolAfterFailed()	test "start a new ReplicationSyncUp after the previous failed".
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.TestReplicationSyncUpToolBase

customizeClusterConf, 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

TestReplicationSyncUpTool

public TestReplicationSyncUpTool()

Method Details

testSyncUpTool

public void testSyncUpTool()
                    throws 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:

Exception

putAndReplicateRows

private void putAndReplicateRows()
                          throws Exception

Throws:

Exception

mimicSyncUpAfterDelete

private void mimicSyncUpAfterDelete()
                             throws Exception

Throws:

Exception

mimicSyncUpAfterPut

private void mimicSyncUpAfterPut()
                          throws Exception

Throws:

Exception

testStartANewSyncUpToolAfterFailed

public void testStartANewSyncUpToolAfterFailed()
                                        throws Exception

test "start a new ReplicationSyncUp after the previous failed". See HBASE-27623 for details.

Throws:

Exception