@InterfaceAudience.Public public class TableRecordReader extends Object implements org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
Modifier and Type | Field and Description |
---|---|
private TableRecordReaderImpl |
recordReaderImpl |
Constructor and Description |
---|
TableRecordReader() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ImmutableBytesWritable |
createKey()
n *
|
Result |
createValue()
n *
|
long |
getPos() |
float |
getProgress() |
void |
init()
Build the scanner.
|
boolean |
next(ImmutableBytesWritable key,
Result value) |
void |
restart(byte[] firstRow)
Restart from survivable exceptions by creating a new scanner.
|
void |
setEndRow(byte[] endRow) |
void |
setHTable(Table htable) |
void |
setInputColumns(byte[][] inputColumns) |
void |
setRowFilter(Filter rowFilter) |
void |
setStartRow(byte[] startRow) |
private TableRecordReaderImpl recordReaderImpl
public TableRecordReader()
public void restart(byte[] firstRow) throws IOException
IOException
public void init() throws IOException
IOException
public void setHTable(Table htable)
htable
- the HTableDescriptor
to scan.public void setInputColumns(byte[][] inputColumns)
inputColumns
- the columns to be placed in Result
.public void setStartRow(byte[] startRow)
startRow
- the first row in the splitpublic void setEndRow(byte[] endRow)
endRow
- the last row in the splitpublic void setRowFilter(Filter rowFilter)
rowFilter
- the Filter
to be used.public void close()
close
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
public ImmutableBytesWritable createKey()
createKey
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
RecordReader.createKey()
public Result createValue()
createValue
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
RecordReader.createValue()
public long getPos()
getPos
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
public float getProgress()
getProgress
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
public boolean next(ImmutableBytesWritable key, Result value) throws IOException
next
in interface org.apache.hadoop.mapred.RecordReader<ImmutableBytesWritable,Result>
key
- HStoreKey as input key.value
- MapWritable as input valueIOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.