public static class TableSnapshotInputFormatImpl.RecordReader extends Object
Modifier and Type | Field and Description |
---|---|
private int |
numOfCompleteRows |
private Result |
result |
private ImmutableBytesWritable |
row |
private int |
rowLimitPerSplit |
private Scan |
scan |
private ClientSideRegionScanner |
scanner |
private TableSnapshotInputFormatImpl.InputSplit |
split |
Constructor and Description |
---|
RecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ImmutableBytesWritable |
getCurrentKey() |
Result |
getCurrentValue() |
long |
getPos() |
float |
getProgress() |
ClientSideRegionScanner |
getScanner() |
void |
initialize(TableSnapshotInputFormatImpl.InputSplit split,
org.apache.hadoop.conf.Configuration conf) |
boolean |
nextKeyValue() |
private TableSnapshotInputFormatImpl.InputSplit split
private ImmutableBytesWritable row
private ClientSideRegionScanner scanner
private int numOfCompleteRows
private int rowLimitPerSplit
public RecordReader()
public ClientSideRegionScanner getScanner()
public void initialize(TableSnapshotInputFormatImpl.InputSplit split, org.apache.hadoop.conf.Configuration conf) throws IOException
IOException
public boolean nextKeyValue() throws IOException
IOException
public ImmutableBytesWritable getCurrentKey()
public Result getCurrentValue()
public long getPos()
public float getProgress()
public void close()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.