Package org.apache.hadoop.hbase.replication.regionserver

Class TestReplicator

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll

org.apache.hadoop.hbase.replication.regionserver.TestReplicator

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestReplicator
extends TestReplicationBaseNoBeforeAll

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestReplicator.FailureInjectingReplicationEndpointForTest
static class	TestReplicator.ReplicationEndpointForTest

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

TestReplicationBaseNoBeforeAll.ReplicationEndpointTest

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final org.slf4j.Logger	LOG
(package private) static final int	NUM_ROWS

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
TestReplicator()

Method Summary

Modifier and Type	Method	Description
static void	setUpBeforeClass()
void	testReplicatorBatching()
void	testReplicatorWithErrors()
private void	truncateTable(HBaseTestingUtil util, org.apache.hadoop.hbase.TableName tablename)

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

static final org.slf4j.Logger LOG

NUM_ROWS

static final int NUM_ROWS

See Also:

• Constant Field Values

Constructor Details

TestReplicator

public TestReplicator()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

testReplicatorBatching

@Test
public void testReplicatorBatching()
                            throws Exception

Throws:

Exception

testReplicatorWithErrors

@Test
public void testReplicatorWithErrors()
                              throws Exception

Throws:

Exception

truncateTable

private void truncateTable(HBaseTestingUtil util,
 org.apache.hadoop.hbase.TableName tablename)
                    throws IOException

Throws:

IOException