org.apache.hadoop.hbase.replication

Class TestVerifyReplication

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestVerifyReplication

public class TestVerifyReplication
extends TestReplicationBase

Field Summary

Fields

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

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

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

Constructor Summary

Constructors

Constructor and Description
TestVerifyReplication()

Method Summary

Modifier and Type	Method and Description
(package private) static void	checkRestoreTmpDir(org.apache.hadoop.conf.Configuration conf, String restoreTmpDir, int expectedCount)
(package private) static void	runBatchCopyTest()
(package private) static void	runVerifyReplication(String[] args, int expectedGoodRows, int expectedBadRows)
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
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.

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

cleanUp, configureClusters, isSerialPeer, loadData, loadData, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, tearDownBase, waitForReplication, 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

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 Detail

TestVerifyReplication

public TestVerifyReplication()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

runVerifyReplication

static void 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

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception