Package org.apache.hadoop.hbase.regionserver.wal

Class AbstractTestProtobufLog<W extends Closeable>

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.AbstractTestProtobufLog<W>

Direct Known Subclasses:

TestAsyncProtobufLog, TestProtobufLog

public abstract class AbstractTestProtobufLog<W extends Closeable>
extends Object

WAL tests that can be reused across providers.

Field Summary

Fields

Modifier and Type	Field	Description
final org.junit.rules.TestName	currentTest
protected org.apache.hadoop.fs.Path	dir
protected org.apache.hadoop.fs.FileSystem	fs
protected static final HBaseTestingUtility	TEST_UTIL
protected org.apache.hadoop.hbase.wal.WALFactory	wals

Constructor Summary

Constructors

Constructor	Description
AbstractTestProtobufLog()

Method Summary

Modifier and Type	Method	Description
protected abstract void	append(W writer, org.apache.hadoop.hbase.wal.WAL.Entry entry)
protected abstract W	createWriter(org.apache.hadoop.fs.Path path)
private void	doRead(boolean withTrailer)	Appends entries in the WAL and reads it.
void	setUp()
static void	setUpBeforeClass()
protected abstract void	sync(W writer)
void	tearDown()
static void	tearDownAfterClass()
void	testWALTrailer()	Reads the WAL with and without WALTrailer.

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

fs

protected org.apache.hadoop.fs.FileSystem fs

dir

protected org.apache.hadoop.fs.Path dir

wals

protected org.apache.hadoop.hbase.wal.WALFactory wals

currentTest

public final org.junit.rules.TestName currentTest

Constructor Details

AbstractTestProtobufLog

public AbstractTestProtobufLog()

Method Details

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testWALTrailer

public void testWALTrailer()
                    throws IOException

Reads the WAL with and without WALTrailer.

Throws:

IOException

doRead

private void doRead(boolean withTrailer)
             throws IOException

Appends entries in the WAL and reads it.

Parameters:

withTrailer - If 'withTrailer' is true, it calls a close on the WALwriter before reading so that a trailer is appended to the WAL. Otherwise, it starts reading after the sync call. This means that reader is not aware of the trailer. In this scenario, if the reader tries to read the trailer in its next() call, it returns false from ProtoBufLogReader.

Throws:

IOException

createWriter

protected abstract W createWriter(org.apache.hadoop.fs.Path path)
                           throws IOException

Throws:

IOException

append

protected abstract void append(W writer,
 org.apache.hadoop.hbase.wal.WAL.Entry entry)
                        throws IOException

Throws:

IOException

sync

protected abstract void sync(W writer)
                      throws IOException

Throws:

IOException