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

Class TestReplicationCompressedWAL

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll

org.apache.hadoop.hbase.replication.regionserver.TestReplicationCompressedWAL

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

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
(package private) static final org.slf4j.Logger	LOG
(package private) static final int	NUM_BATCHES
(package private) static final int	NUM_ROWS_PER_BATCH

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

Method Summary

Modifier and Type	Method	Description
protected static void	getBatch(int batch)
protected static byte[]	getRowKey(int batch, int count)
protected static void	putBatch(int batch)
protected static void	runMultiplePutTest()
static void	setUpBeforeClass()
void	testMultiplePuts()

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_BATCHES

static final int NUM_BATCHES

See Also:

• Constant Field Values

NUM_ROWS_PER_BATCH

static final int NUM_ROWS_PER_BATCH

See Also:

• Constant Field Values

Constructor Details

TestReplicationCompressedWAL

public TestReplicationCompressedWAL()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

testMultiplePuts

@Test
public void testMultiplePuts()
                      throws Exception

Throws:

Exception

runMultiplePutTest

protected static void runMultiplePutTest()
                                  throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getBatch

protected static void getBatch(int batch)
                        throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getRowKey

protected static byte[] getRowKey(int batch,
 int count)

putBatch

protected static void putBatch(int batch)
                        throws IOException

Throws:

IOException