Package org.apache.hadoop.hbase.replication

Class VerifyReplicationTestBase

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.VerifyReplicationTestBase

Direct Known Subclasses:

TestVerifyReplicationRpcConnectionUri, TestVerifyReplicationZkClusterKey, TestVerifyReplicationZkConnectionUri

public abstract class VerifyReplicationTestBase
extends TestReplicationBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

TestReplicationBase.ReplicationEndpointTest

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Table	htable3
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static final String	PEER_ID
private static final org.apache.hadoop.hbase.TableName	peerTableName

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

CONF_WITH_LOCALFS, CONF1, CONF2, connection1, connection2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, replicateCount, replicatedEntries, row, SLEEP_TIME, tableName, UTIL1, UTIL2

Constructor Summary

Constructors

Constructor	Description
VerifyReplicationTestBase()

Method Summary

Modifier and Type	Method	Description
(package private) static void	checkRestoreTmpDir(org.apache.hadoop.conf.Configuration conf, String restoreTmpDir, int expectedCount)
(package private) static void	runBatchCopyTest()
(package private) static org.apache.hadoop.mapreduce.Counters	runVerifyReplication(String[] args, int expectedGoodRows, int expectedBadRows)
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testFailsRemainingComparesAfterShutdown()
void	testVerifyRepJob()	Do a small loading into a table, make sure the data is really the same, then run the VerifyReplication job to check the results.
void	testVerifyRepJobWithPeerTableName()
void	testVerifyRepJobWithPeerTableNameAndSnapshotSupport()
void	testVerifyRepJobWithQuorumAddress()
void	testVerifyRepJobWithQuorumAddressAndSnapshotSupport()
void	testVerifyRepJobWithRawOptions()	Load a row into a table, make sure the data is really the same, delete the row, make sure the delete marker is replicated, run verify replication with and without raw to check the results.
void	testVerifyReplicationSynchronousRecompares()
void	testVerifyReplicationThreadedRecompares()

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

addPeer, cleanUp, configureClusters, createTable, getClusterKey, isSerialPeer, isSyncPeer, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, stopAllRegionServers, tearDownBase, waitForReplication, waitForReplication

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

PEER_ID

private static final String PEER_ID

See Also:

• Constant Field Values

peerTableName

private static final org.apache.hadoop.hbase.TableName peerTableName

htable3

private static org.apache.hadoop.hbase.client.Table htable3

name

public org.junit.rules.TestName name

Constructor Details

VerifyReplicationTestBase

public VerifyReplicationTestBase()

Method Details

setUp

public void setUp()
           throws Exception

Throws:

Exception

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

runVerifyReplication

static org.apache.hadoop.mapreduce.Counters runVerifyReplication(String[] args,
 int expectedGoodRows,
 int expectedBadRows)
                                                          throws IOException,
InterruptedException,
ClassNotFoundException

Throws:

IOException

InterruptedException

ClassNotFoundException

testVerifyRepJob

public void testVerifyRepJob()
                      throws Exception

Do a small loading into a table, make sure the data is really the same, then run the VerifyReplication job to check the results. Do a second comparison where all the cells are different.

Throws:

Exception

testVerifyRepJobWithRawOptions

public void testVerifyRepJobWithRawOptions()
                                    throws Exception

Load a row into a table, make sure the data is really the same, delete the row, make sure the delete marker is replicated, run verify replication with and without raw to check the results.

Throws:

Exception

checkRestoreTmpDir

static void checkRestoreTmpDir(org.apache.hadoop.conf.Configuration conf,
 String restoreTmpDir,
 int expectedCount)
                        throws IOException

Throws:

IOException

testVerifyRepJobWithQuorumAddress

public void testVerifyRepJobWithQuorumAddress()
                                       throws Exception

Throws:

Exception

testVerifyRepJobWithQuorumAddressAndSnapshotSupport

public void testVerifyRepJobWithQuorumAddressAndSnapshotSupport()
                                                         throws Exception

Throws:

Exception

runBatchCopyTest

static void runBatchCopyTest()
                      throws Exception

Throws:

Exception

testVerifyRepJobWithPeerTableName

public void testVerifyRepJobWithPeerTableName()
                                       throws Exception

Throws:

Exception

testVerifyRepJobWithPeerTableNameAndSnapshotSupport

public void testVerifyRepJobWithPeerTableNameAndSnapshotSupport()
                                                         throws Exception

Throws:

Exception

testVerifyReplicationThreadedRecompares

public void testVerifyReplicationThreadedRecompares()
                                             throws Exception

Throws:

Exception

testFailsRemainingComparesAfterShutdown

public void testFailsRemainingComparesAfterShutdown()
                                             throws Exception

Throws:

Exception

testVerifyReplicationSynchronousRecompares

public void testVerifyReplicationSynchronousRecompares()
                                                throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception