org.apache.hadoop.hbase.snapshot

Class ExportSnapshot.ExportSnapshotInputFormat.ExportSnapshotRecordReader

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>

org.apache.hadoop.hbase.snapshot.ExportSnapshot.ExportSnapshotInputFormat.ExportSnapshotRecordReader

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

ExportSnapshot.ExportSnapshotInputFormat

private static class ExportSnapshot.ExportSnapshotInputFormat.ExportSnapshotRecordReader
extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>

Field Summary

Fields

Modifier and Type	Field and Description
private List<Pair<org.apache.hadoop.io.BytesWritable,Long>>	files
private int	index
private long	procSize
private long	totalSize

Constructor Summary

Constructors

Constructor and Description
ExportSnapshotRecordReader(List<Pair<org.apache.hadoop.io.BytesWritable,Long>> files)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.BytesWritable	getCurrentKey()
org.apache.hadoop.io.NullWritable	getCurrentValue()
float	getProgress()
void	initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext tac)
boolean	nextKeyValue()

Methods inherited from class java.lang.Object

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

Field Detail

files

private final List<Pair<org.apache.hadoop.io.BytesWritable,Long>> files

totalSize

private long totalSize

procSize

private long procSize

index

private int index

Constructor Detail

ExportSnapshotRecordReader

ExportSnapshotRecordReader(List<Pair<org.apache.hadoop.io.BytesWritable,Long>> files)

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>

getCurrentKey

public org.apache.hadoop.io.BytesWritable getCurrentKey()

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>

getCurrentValue

public org.apache.hadoop.io.NullWritable getCurrentValue()

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>

getProgress

public float getProgress()

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit split,
                       org.apache.hadoop.mapreduce.TaskAttemptContext tac)

Specified by:

initialize in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>

nextKeyValue

public boolean nextKeyValue()

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.NullWritable>