static class TableSnapshotInputFormat.TableSnapshotRecordReader extends Object implements org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
Modifier and Type | Field and Description |
---|---|
private TableSnapshotInputFormatImpl.RecordReader |
delegate |
Constructor and Description |
---|
TableSnapshotInputFormat.TableSnapshotRecordReader(TableSnapshotInputFormat.TableSnapshotRegionSplit split,
org.apache.hadoop.mapred.JobConf job) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ImmutableBytesWritable |
createKey() |
Result |
createValue() |
long |
getPos() |
float |
getProgress() |
boolean |
next(ImmutableBytesWritable key,
Result value) |
private TableSnapshotInputFormatImpl.RecordReader delegate
public TableSnapshotInputFormat.TableSnapshotRecordReader(TableSnapshotInputFormat.TableSnapshotRegionSplit split, org.apache.hadoop.mapred.JobConf job) throws IOException
IOException
public boolean next(ImmutableBytesWritable key, Result value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
IOException
public ImmutableBytesWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
public Result createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
public long getPos() throws IOException
getPos
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
IOException
public void close() throws IOException
close
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
IOException
public float getProgress() throws IOException
getProgress
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
IOException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.