org.apache.pig.backend.hadoop.hbase
Class HBaseTableInputFormat.HBaseTableRecordReader

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>
      extended by org.apache.hadoop.hbase.mapreduce.TableRecordReader
          extended by 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


Constructor Summary
HBaseTableInputFormat.HBaseTableRecordReader(long limit)
           
 
Method Summary
 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


Copyright © 2007-2012 The Apache Software Foundation