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

Class WALDurabilityTestBase<T extends org.apache.hadoop.hbase.wal.WAL>

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.WALDurabilityTestBase<T>

Direct Known Subclasses:

TestAsyncFSWALDurability, TestFSHLogDurability

public abstract class WALDurabilityTestBase<T extends org.apache.hadoop.hbase.wal.WAL>
extends Object

Tests for WAL write durability - hflush vs hsync

Field Summary

Fields

Modifier and Type	Field	Description
private static final String	COLUMN_FAMILY
private static final byte[]	COLUMN_FAMILY_BYTES
private org.apache.hadoop.conf.Configuration	conf
private String	dir
org.junit.rules.TestName	name
protected org.apache.hadoop.hbase.TableName	tableName
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
WALDurabilityTestBase()

Method Summary

Modifier and Type	Method	Description
private String	getName()
protected abstract Boolean	getSyncFlag(T wal)
protected final T	getWAL(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path root, String logDir, org.apache.hadoop.conf.Configuration conf)
protected abstract T	getWAL0(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path root, String logDir, org.apache.hadoop.conf.Configuration conf)
protected abstract Boolean	getWriterSyncFlag(T wal)
static org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(org.apache.hadoop.hbase.TableName tableName, byte[] startKey, byte[] stopKey, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.wal.WAL wal)
protected abstract void	resetSyncFlag(T wal)
void	setUp()
void	tearDown()
void	testWALDurability()

Methods inherited from class java.lang.Object

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

Field Details

COLUMN_FAMILY

private static final String COLUMN_FAMILY

See Also:

• Constant Field Values

COLUMN_FAMILY_BYTES

private static final byte[] COLUMN_FAMILY_BYTES

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

conf

private org.apache.hadoop.conf.Configuration conf

dir

private String dir

name

public org.junit.rules.TestName name

tableName

protected org.apache.hadoop.hbase.TableName tableName

Constructor Details

WALDurabilityTestBase

public WALDurabilityTestBase()

Method Details

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

getWAL

protected final T getWAL(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path root,
 String logDir,
 org.apache.hadoop.conf.Configuration conf)
                  throws IOException

Throws:

IOException

getWAL0

protected abstract T getWAL0(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path root,
 String logDir,
 org.apache.hadoop.conf.Configuration conf)
                      throws IOException

Throws:

IOException

resetSyncFlag

protected abstract void resetSyncFlag(T wal)

getSyncFlag

protected abstract Boolean getSyncFlag(T wal)

getWriterSyncFlag

protected abstract Boolean getWriterSyncFlag(T wal)

testWALDurability

public void testWALDurability()
                       throws IOException

Throws:

IOException

getName

private String getName()

initHRegion

public static org.apache.hadoop.hbase.regionserver.HRegion initHRegion(org.apache.hadoop.hbase.TableName tableName,
 byte[] startKey,
 byte[] stopKey,
 org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.wal.WAL wal)
                                                                throws IOException

Returns:

A region on which you must call HBaseTestingUtil.closeRegionAndWAL(HRegion) when done.

Throws:

IOException