static class TableSnapshotInputFormat.TableSnapshotRegionRecordReader extends org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
| Modifier and Type | Field and Description |
|---|---|
private org.apache.hadoop.mapreduce.TaskAttemptContext |
context |
private TableSnapshotInputFormatImpl.RecordReader |
delegate |
private Method |
getCounter |
| Constructor and Description |
|---|
TableSnapshotInputFormat.TableSnapshotRegionRecordReader() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
ImmutableBytesWritable |
getCurrentKey() |
Result |
getCurrentValue() |
float |
getProgress() |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
boolean |
nextKeyValue() |
private TableSnapshotInputFormatImpl.RecordReader delegate
private org.apache.hadoop.mapreduce.TaskAttemptContext context
private Method getCounter
TableSnapshotInputFormat.TableSnapshotRegionRecordReader()
public void initialize(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws IOException,
InterruptedException
initialize in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>IOExceptionInterruptedExceptionpublic boolean nextKeyValue()
throws IOException,
InterruptedException
nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>IOExceptionInterruptedExceptionpublic ImmutableBytesWritable getCurrentKey() throws IOException, InterruptedException
getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>IOExceptionInterruptedExceptionpublic Result getCurrentValue() throws IOException, InterruptedException
getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>IOExceptionInterruptedExceptionpublic float getProgress()
throws IOException,
InterruptedException
getProgress in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>IOExceptionInterruptedExceptionpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>IOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.