Package org.apache.hadoop.hbase.mapreduce

Class WALInputFormat.WALRecordReader<K extends WALKey>

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<K,WALEdit>

org.apache.hadoop.hbase.mapreduce.WALInputFormat.WALRecordReader<K>

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

WALInputFormat.WALKeyRecordReader

Enclosing class:

WALInputFormat

abstract static class WALInputFormat.WALRecordReader<K extends WALKey>
extends org.apache.hadoop.mapreduce.RecordReader<K,WALEdit>

RecordReader for an WAL file. Implementation shared with deprecated HLogInputFormat.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
(package private) WAL.Entry	currentEntry
private long	currentPos
private long	endTime
private org.apache.hadoop.fs.Path	logFile
private WALStreamReader	reader
private long	startTime

Constructor Summary

Constructors

Constructor	Description
WALRecordReader()

Method Summary

Modifier and Type	Method	Description
void	close()
private void	closeReader()
WALEdit	getCurrentValue()
float	getProgress()
void	initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
boolean	nextKeyValue()
private void	openReader(org.apache.hadoop.fs.Path path)
private WALStreamReader	openReader(org.apache.hadoop.fs.Path path, long startPosition)
private void	setCurrentPath(org.apache.hadoop.fs.Path path)

Methods inherited from class org.apache.hadoop.mapreduce.RecordReader

getCurrentKey

Methods inherited from class java.lang.Object

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

Field Details

reader

private WALStreamReader reader

currentEntry

WAL.Entry currentEntry

startTime

private long startTime

endTime

private long endTime

conf

private org.apache.hadoop.conf.Configuration conf

logFile

private org.apache.hadoop.fs.Path logFile

currentPos

private long currentPos

Constructor Details

WALRecordReader

WALRecordReader()

Method Details

openReader

private WALStreamReader openReader(org.apache.hadoop.fs.Path path,
 long startPosition)
                            throws IOException

Throws:

IOException

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit split,
 org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws IOException,
InterruptedException

Specified by:

initialize in class org.apache.hadoop.mapreduce.RecordReader<K extends WALKey,WALEdit>

Throws:

IOException

InterruptedException

openReader

private void openReader(org.apache.hadoop.fs.Path path)
                 throws IOException

Throws:

IOException

setCurrentPath

private void setCurrentPath(org.apache.hadoop.fs.Path path)

closeReader

private void closeReader()
                  throws IOException

Throws:

IOException

nextKeyValue

public boolean nextKeyValue()
                     throws IOException,
InterruptedException

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<K extends WALKey,WALEdit>

Throws:

IOException

InterruptedException

getCurrentValue

public WALEdit getCurrentValue()
                        throws IOException,
InterruptedException

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<K extends WALKey,WALEdit>

Throws:

IOException

InterruptedException

getProgress

public float getProgress()
                  throws IOException,
InterruptedException

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<K extends WALKey,WALEdit>

Throws:

IOException

InterruptedException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<K extends WALKey,WALEdit>

Throws:

IOException