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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>
      extended by org.apache.hadoop.hbase.mapreduce.TableInputFormatBase
          extended by org.apache.hadoop.hbase.mapreduce.TableInputFormat
              extended by org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable

public class HBaseTableInputFormat
extends org.apache.hadoop.hbase.mapreduce.TableInputFormat


Nested Class Summary
static class HBaseTableInputFormat.HBaseTableIFBuilder
           
protected  class HBaseTableInputFormat.HBaseTableRecordReader
           
 
Field Summary
protected  byte[] gt_
           
protected  byte[] gte_
           
protected  byte[] lt_
           
protected  byte[] lte_
           
 
Fields inherited from class org.apache.hadoop.hbase.mapreduce.TableInputFormat
INPUT_TABLE, SCAN, SCAN_CACHEBLOCKS, SCAN_CACHEDROWS, SCAN_COLUMN_FAMILY, SCAN_COLUMNS, SCAN_MAXVERSIONS, SCAN_TIMERANGE_END, SCAN_TIMERANGE_START, SCAN_TIMESTAMP
 
Constructor Summary
  HBaseTableInputFormat()
           
protected HBaseTableInputFormat(long limit, byte[] gt, byte[] gte, byte[] lt, byte[] lte)
           
 
Method Summary
 List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
           
 
Methods inherited from class org.apache.hadoop.hbase.mapreduce.TableInputFormat
getConf, setConf
 
Methods inherited from class org.apache.hadoop.hbase.mapreduce.TableInputFormatBase
createRecordReader, getHTable, getScan, includeRegionInSplit, setHTable, setScan, setTableRecordReader
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

gt_

protected final byte[] gt_

gte_

protected final byte[] gte_

lt_

protected final byte[] lt_

lte_

protected final byte[] lte_
Constructor Detail

HBaseTableInputFormat

public HBaseTableInputFormat()

HBaseTableInputFormat

protected HBaseTableInputFormat(long limit,
                                byte[] gt,
                                byte[] gte,
                                byte[] lt,
                                byte[] lte)
Method Detail

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                       throws IOException
Overrides:
getSplits in class org.apache.hadoop.hbase.mapreduce.TableInputFormatBase
Throws:
IOException


Copyright © ${year} The Apache Software Foundation