Package org.apache.hadoop.hbase.replication

Class VerifyReplicationTestBase

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll

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.TestReplicationBaseNoBeforeAll

TestReplicationBaseNoBeforeAll.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
private static final String	PEER_ID
private static final org.apache.hadoop.hbase.TableName	peerTableName

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

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(org.junit.jupiter.api.TestInfo testInfo)	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.TestReplicationBaseNoBeforeAll

addPeer, addPeer, cleanUp, configureClusters, createTable, getClusterKey, isSerialPeer, isSyncPeer, loadData, loadData, removePeer, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, startClusters, 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

Constructor Details

VerifyReplicationTestBase

public VerifyReplicationTestBase()

Method Details

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

setUpBeforeClass

@BeforeAll
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

@Test
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

@Test
public void testVerifyRepJobWithRawOptions(org.junit.jupiter.api.TestInfo testInfo)
                                    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

@Test
public void testVerifyRepJobWithQuorumAddress()
                                       throws Exception

Throws:

Exception

testVerifyRepJobWithQuorumAddressAndSnapshotSupport

@Test
public void testVerifyRepJobWithQuorumAddressAndSnapshotSupport()
                                                         throws Exception

Throws:

Exception

runBatchCopyTest

static void runBatchCopyTest()
                      throws Exception

Throws:

Exception

testVerifyRepJobWithPeerTableName

@Test
public void testVerifyRepJobWithPeerTableName()
                                       throws Exception

Throws:

Exception

testVerifyRepJobWithPeerTableNameAndSnapshotSupport

@Test
public void testVerifyRepJobWithPeerTableNameAndSnapshotSupport()
                                                         throws Exception

Throws:

Exception

testVerifyReplicationThreadedRecompares

@Test
public void testVerifyReplicationThreadedRecompares()
                                             throws Exception

Throws:

Exception

testFailsRemainingComparesAfterShutdown

@Test
public void testFailsRemainingComparesAfterShutdown()
                                             throws Exception

Throws:

Exception

testVerifyReplicationSynchronousRecompares

@Test
public void testVerifyReplicationSynchronousRecompares()
                                                throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception