Class TableSnapshotInputFormat.TableSnapshotRegionRecordReader
java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
org.apache.hadoop.hbase.mapreduce.TableSnapshotInputFormat.TableSnapshotRegionRecordReader
- All Implemented Interfaces:
Closeable
,AutoCloseable
- Enclosing class:
- TableSnapshotInputFormat
@Private
static class TableSnapshotInputFormat.TableSnapshotRegionRecordReader
extends org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
-
Field Summary
Modifier and TypeFieldDescriptionprivate org.apache.hadoop.mapreduce.TaskAttemptContext
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
float
void
initialize
(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) boolean
-
Field Details
-
delegate
-
context
-
-
Constructor Details
-
TableSnapshotRegionRecordReader
-
-
Method Details
-
initialize
public void initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException - Specified by:
initialize
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
InterruptedException
-
nextKeyValue
- Specified by:
nextKeyValue
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
InterruptedException
-
getCurrentKey
- Specified by:
getCurrentKey
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
InterruptedException
-
getCurrentValue
- Specified by:
getCurrentValue
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
InterruptedException
-
getProgress
- Specified by:
getProgress
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
InterruptedException
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in classorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,
Result> - Throws:
IOException
-