org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationCompressedWAL

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

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

public class TestReplicationCompressedWAL
extends TestReplicationBase

Nested Class Summary

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

TestReplicationBase.ReplicationEndpointTest

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
(package private) static org.slf4j.Logger	LOG
(package private) static int	NUM_BATCHES
(package private) static int	NUM_ROWS_PER_BATCH

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

admin, 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 and Description
TestReplicationCompressedWAL()

Method Summary

Modifier and Type	Method and 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()
static void	tearDownAfterClass()
void	testMultiplePuts()

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

addPeer, cleanUp, createTable, isSerialPeer, loadData, loadData, removePeer, 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

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 Detail

TestReplicationCompressedWAL

public TestReplicationCompressedWAL()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testMultiplePuts

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