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.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static String	PEER_ID

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, row, scopes, seperateOldWALs, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2

Constructor Summary

Constructors

Constructor and Description
TestVerifyReplication()

Method Summary

Modifier and Type	Method and Description
private void	checkRestoreTmpDir(org.apache.hadoop.conf.Configuration conf, String restoreTmpDir, int expectedCount)
private void	runVerifyReplication(String[] args, int expectedGoodRows, int expectedBadRows)
void	setUp()
void	testHBase14905()
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	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	testVerifyReplicationPrefixFiltering()
void	testVerifyReplicationSnapshotArguments()
void	testVerifyReplicationWithSnapshotSupport()
void	testVersionMismatchHBase14905()

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

cleanUp, loadData, params, runSimplePutDeleteTest, runSmallBatchTest, setUpBeforeClass, 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

PEER_ID

private static final String PEER_ID

See Also:

Constant Field Values

name

public org.junit.rules.TestName name

Constructor Detail

TestVerifyReplication

public TestVerifyReplication()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

runVerifyReplication

private 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

testHBase14905

public void testHBase14905()
                    throws Exception

Throws:

Exception

testVersionMismatchHBase14905

public void testVersionMismatchHBase14905()
                                   throws Exception

Throws:

Exception

testVerifyReplicationPrefixFiltering

public void testVerifyReplicationPrefixFiltering()
                                          throws Exception

Throws:

Exception

testVerifyReplicationSnapshotArguments

public void testVerifyReplicationSnapshotArguments()

checkRestoreTmpDir

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

Throws:

IOException

testVerifyReplicationWithSnapshotSupport

public void testVerifyReplicationWithSnapshotSupport()
                                              throws Exception

Throws:

Exception