|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
org.apache.hadoop.hbase.mapreduce.TableRecordReader
public class TableRecordReader
Iterate over an HBase table data, return (ImmutableBytesWritable, Result) pairs.
Constructor Summary | |
---|---|
TableRecordReader()
|
Method Summary | |
---|---|
void |
close()
Closes the split. |
ImmutableBytesWritable |
getCurrentKey()
Returns the current key. |
Result |
getCurrentValue()
Returns the current value. |
float |
getProgress()
The current progress of the record reader through its data. |
void |
init()
Build the scanner. |
void |
initialize(org.apache.hadoop.mapreduce.InputSplit inputsplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Initializes the reader. |
boolean |
nextKeyValue()
Positions the record reader to the next record. |
void |
restart(byte[] firstRow)
Restart from survivable exceptions by creating a new scanner. |
void |
setHTable(HTable htable)
Sets the HBase table. |
void |
setScan(Scan scan)
Sets the scan defining the actual details like columns etc. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TableRecordReader()
Method Detail |
---|
public void restart(byte[] firstRow) throws IOException
firstRow
- The first row to start at.
IOException
- When restarting fails.public void init() throws IOException
IOException
- When restarting the scan fails.public void setHTable(HTable htable)
htable
- The HTable
to scan.public void setScan(Scan scan)
scan
- The scan to set.public void close()
close
in interface Closeable
close
in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
RecordReader.close()
public ImmutableBytesWritable getCurrentKey() throws IOException, InterruptedException
getCurrentKey
in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
IOException
InterruptedException
- When the job is aborted.RecordReader.getCurrentKey()
public Result getCurrentValue() throws IOException, InterruptedException
getCurrentValue
in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
IOException
- When the value is faulty.
InterruptedException
- When the job is aborted.RecordReader.getCurrentValue()
public void initialize(org.apache.hadoop.mapreduce.InputSplit inputsplit, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
initialize
in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
inputsplit
- The split to work with.context
- The current task context.
IOException
- When setting up the reader fails.
InterruptedException
- When the job is aborted.RecordReader.initialize(
org.apache.hadoop.mapreduce.InputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext)
public boolean nextKeyValue() throws IOException, InterruptedException
nextKeyValue
in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
true
if there was another record.
IOException
- When reading the record failed.
InterruptedException
- When the job was aborted.RecordReader.nextKeyValue()
public float getProgress()
getProgress
in class org.apache.hadoop.mapreduce.RecordReader<ImmutableBytesWritable,Result>
RecordReader.getProgress()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |