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, AutoCloseable

Enclosing class:

HBaseTableInputFormat

protected class HBaseTableInputFormat.HBaseTableRecordReader
extends org.apache.hadoop.hbase.mapreduce.TableRecordReader

Constructor Summary

Constructors

Constructor and Description
HBaseTableInputFormat.HBaseTableRecordReader(long limit)

Method Summary

Methods

Modifier and Type	Method and Description
float	getProgress()
boolean	nextKeyValue()
void	setScan(org.apache.hadoop.hbase.client.Scan scan)

Methods inherited from class org.apache.hadoop.hbase.mapreduce.TableRecordReader

close, getCurrentKey, getCurrentValue, initialize, restart, setHTable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HBaseTableInputFormat.HBaseTableRecordReader

public HBaseTableInputFormat.HBaseTableRecordReader(long limit)

Method Detail

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