Package org.apache.hadoop.hbase.mapreduce

Class TestWALRecordReader

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestWALRecordReader

public class TestWALRecordReader
extends Object

JUnit tests for the WALRecordReader

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	conf
private static final byte[]	family
private static org.apache.hadoop.fs.FileSystem	fs
private static org.apache.hadoop.fs.Path	hbaseDir
(package private) static final org.apache.hadoop.hbase.client.RegionInfo	info
private static final org.slf4j.Logger	LOG
private static org.apache.hadoop.fs.Path	logDir
protected org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl	mvcc
private static final byte[]	rowName
protected static NavigableMap<byte[],Integer>	scopes
(package private) static final org.apache.hadoop.hbase.TableName	tableName
private static final HBaseTestingUtil	TEST_UTIL
private static final byte[]	value
private static org.apache.hadoop.fs.FileSystem	walFs
private static org.apache.hadoop.fs.Path	walRootDir

Constructor Summary

Constructors

Constructor	Description
TestWALRecordReader()

Method Summary

Modifier and Type	Method	Description
private static String	getName()
private org.apache.hadoop.hbase.mapreduce.WALInputFormat.WALRecordReader<org.apache.hadoop.hbase.wal.WALKey>	getReader()
private static String	getServerName()
private org.apache.hadoop.fs.Path	getWALArchiveDir(org.apache.hadoop.conf.Configuration conf)
protected org.apache.hadoop.hbase.wal.WALKeyImpl	getWalKeyImpl(long time, NavigableMap<byte[],Integer> scopes)
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testPartialRead()	Test partial reads from the WALs based on passed time range.
private void	testSplit(org.apache.hadoop.mapreduce.InputSplit split, byte[]... columns)	Create a new reader from the split, and match the edits against the passed columns.
private void	testSplitWithMovingWAL(org.apache.hadoop.mapreduce.InputSplit split, byte[] col1, byte[] col2)	Create a new reader from the split, match the edits against the passed columns, moving WAL to archive in between readings
void	testWALRecordReader()	Test basic functionality
void	testWALRecordReaderActiveArchiveTolerance()	Test WALRecordReader tolerance to moving WAL from active to archive directory

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

conf

private static org.apache.hadoop.conf.Configuration conf

fs

private static org.apache.hadoop.fs.FileSystem fs

hbaseDir

private static org.apache.hadoop.fs.Path hbaseDir

walFs

private static org.apache.hadoop.fs.FileSystem walFs

walRootDir

private static org.apache.hadoop.fs.Path walRootDir

tableName

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

rowName

private static final byte[] rowName

info

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

family

private static final byte[] family

value

private static final byte[] value

logDir

private static org.apache.hadoop.fs.Path logDir

mvcc

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

scopes

protected static NavigableMap<byte[],Integer> scopes

Constructor Details

TestWALRecordReader

public TestWALRecordReader()

Method Details

getName

private static String getName()

getServerName

private static String getServerName()

setUp

public void setUp()
           throws Exception

Throws:

Exception

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testPartialRead

public void testPartialRead()
                     throws Exception

Test partial reads from the WALs based on passed time range.

Throws:

Exception

testWALRecordReader

public void testWALRecordReader()
                         throws Exception

Test basic functionality

Throws:

Exception

testWALRecordReaderActiveArchiveTolerance

public void testWALRecordReaderActiveArchiveTolerance()
                                               throws Exception

Test WALRecordReader tolerance to moving WAL from active to archive directory

Throws:

Exception - exception

getWalKeyImpl

protected org.apache.hadoop.hbase.wal.WALKeyImpl getWalKeyImpl(long time,
 NavigableMap<byte[],Integer> scopes)

getReader

private org.apache.hadoop.hbase.mapreduce.WALInputFormat.WALRecordReader<org.apache.hadoop.hbase.wal.WALKey> getReader()

testSplit

private void testSplit(org.apache.hadoop.mapreduce.InputSplit split,
 byte[]... columns)
                throws Exception

Create a new reader from the split, and match the edits against the passed columns.

Throws:

Exception

testSplitWithMovingWAL

private void testSplitWithMovingWAL(org.apache.hadoop.mapreduce.InputSplit split,
 byte[] col1,
 byte[] col2)
                             throws Exception

Create a new reader from the split, match the edits against the passed columns, moving WAL to archive in between readings

Throws:

Exception

getWALArchiveDir

private org.apache.hadoop.fs.Path getWALArchiveDir(org.apache.hadoop.conf.Configuration conf)
                                            throws IOException

Throws:

IOException