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

Class WALEntryStreamTestBase

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.WALEntryStreamTestBase

Direct Known Subclasses:

TestBasicWALEntryStream, TestWALEntryStreamDifferentCounts

public abstract class WALEntryStreamTestBase
extends Object

Base class for WALEntryStream tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	WALEntryStreamTestBase.PathWatcher
protected static class	WALEntryStreamTestBase.WALEntryStreamWithRetries	Test helper that waits until a non-null entry is available in the stream next or times out.

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.apache.hadoop.hdfs.MiniDFSCluster	cluster
protected static org.apache.hadoop.conf.Configuration	CONF
protected final String	fakeWalGroupId
protected static final byte[]	family
protected static org.apache.hadoop.hdfs.DistributedFileSystem	fs
protected static final org.apache.hadoop.hbase.client.RegionInfo	info
protected org.apache.hadoop.hbase.wal.WAL	log
protected org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue	logQueue
protected final org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl	mvcc
protected WALEntryStreamTestBase.PathWatcher	pathWatcher
protected static final byte[]	qualifier
protected static final NavigableMap<byte[],Integer>	scopes
protected static final org.apache.hadoop.hbase.TableName	tableName
protected static final long	TEST_TIMEOUT_MS
protected static HBaseTestingUtil	TEST_UTIL
org.junit.rules.TestName	tn

Constructor Summary

Constructors

Constructor	Description
WALEntryStreamTestBase()

Method Summary

Modifier and Type	Method	Description
protected long	appendToLog(int count)
protected void	appendToLogAndSync()
protected void	appendToLogAndSync(int count)
private static NavigableMap<byte[],Integer>	getScopes()
protected org.apache.hadoop.hbase.wal.WALEdit	getWALEdits(int count)
protected void	initWAL()
protected static void	startCluster()
void	tearDown()
static void	tearDownAfterClass()

Methods inherited from class java.lang.Object

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

Field Details

TEST_TIMEOUT_MS

protected static final long TEST_TIMEOUT_MS

See Also:

• Constant Field Values

TEST_UTIL

protected static HBaseTestingUtil TEST_UTIL

CONF

protected static org.apache.hadoop.conf.Configuration CONF

fs

protected static org.apache.hadoop.hdfs.DistributedFileSystem fs

cluster

protected static org.apache.hadoop.hdfs.MiniDFSCluster cluster

tableName

protected static final org.apache.hadoop.hbase.TableName tableName

family

protected static final byte[] family

qualifier

protected static final byte[] qualifier

info

protected static final org.apache.hadoop.hbase.client.RegionInfo info

scopes

protected static final NavigableMap<byte[],Integer> scopes

fakeWalGroupId

protected final String fakeWalGroupId

See Also:

• Constant Field Values

log

protected org.apache.hadoop.hbase.wal.WAL log

logQueue

protected org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue logQueue

pathWatcher

protected WALEntryStreamTestBase.PathWatcher pathWatcher

tn

public org.junit.rules.TestName tn

mvcc

protected final org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl mvcc

Constructor Details

WALEntryStreamTestBase

public WALEntryStreamTestBase()

Method Details

getScopes

private static NavigableMap<byte[],Integer> getScopes()

startCluster

protected static void startCluster()
                            throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

initWAL

protected void initWAL()
                throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

appendToLogAndSync

protected void appendToLogAndSync()
                           throws IOException

Throws:

IOException

appendToLogAndSync

protected void appendToLogAndSync(int count)
                           throws IOException

Throws:

IOException

appendToLog

protected long appendToLog(int count)
                    throws IOException

Throws:

IOException

getWALEdits

protected org.apache.hadoop.hbase.wal.WALEdit getWALEdits(int count)