org.apache.pig.backend.hadoop.hbase
Class HBaseTableInputFormat.HBaseTableRecordReader
java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>
org.apache.hadoop.hbase.mapreduce.TableRecordReader
org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat.HBaseTableRecordReader
- All Implemented Interfaces:
- Closeable
- Enclosing class:
- HBaseTableInputFormat
protected class HBaseTableInputFormat.HBaseTableRecordReader
- extends org.apache.hadoop.hbase.mapreduce.TableRecordReader
Methods inherited from class org.apache.hadoop.hbase.mapreduce.TableRecordReader |
close, getCurrentKey, getCurrentValue, init, initialize, restart, setHTable |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HBaseTableInputFormat.HBaseTableRecordReader
public HBaseTableInputFormat.HBaseTableRecordReader(long limit)
setScan
public void setScan(org.apache.hadoop.hbase.client.Scan scan)
- Overrides:
setScan
in class org.apache.hadoop.hbase.mapreduce.TableRecordReader
nextKeyValue
public boolean nextKeyValue()
throws IOException,
InterruptedException
- Overrides:
nextKeyValue
in class org.apache.hadoop.hbase.mapreduce.TableRecordReader
- Throws:
IOException
InterruptedException
getProgress
public float getProgress()
- Overrides:
getProgress
in class org.apache.hadoop.hbase.mapreduce.TableRecordReader
Copyright © ${year} The Apache Software Foundation