Package org.apache.hadoop.hbase.mapred

Class TableSnapshotInputFormat.TableSnapshotRecordReader

java.lang.Object

org.apache.hadoop.hbase.mapred.TableSnapshotInputFormat.TableSnapshotRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

Enclosing class:

TableSnapshotInputFormat

static class TableSnapshotInputFormat.TableSnapshotRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

Field Summary

Fields

Modifier and Type	Field	Description
private TableSnapshotInputFormatImpl.RecordReader	delegate

Constructor Summary

Constructors

Constructor	Description
TableSnapshotRecordReader(TableSnapshotInputFormat.TableSnapshotRegionSplit split, org.apache.hadoop.mapred.JobConf job)

Method Summary

Modifier and Type	Method	Description
void	close()
ImmutableBytesWritable	createKey()
Result	createValue()
long	getPos()
float	getProgress()
boolean	next(ImmutableBytesWritable key, Result value)

Methods inherited from class java.lang.Object

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

Field Details

delegate

private TableSnapshotInputFormatImpl.RecordReader delegate

Constructor Details

TableSnapshotRecordReader

public TableSnapshotRecordReader(TableSnapshotInputFormat.TableSnapshotRegionSplit split,
 org.apache.hadoop.mapred.JobConf job)
                          throws IOException

Throws:

IOException

Method Details

next

public boolean next(ImmutableBytesWritable key,
 Result value)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

Throws:

IOException

createKey

public ImmutableBytesWritable createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

createValue

public Result createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>

Throws:

IOException