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

java.lang.Object
  org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>
      org.apache.hadoop.hbase.mapreduce.TableInputFormatBase
          org.apache.hadoop.hbase.mapreduce.TableInputFormat
              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_ROW_START, SCAN_ROW_STOP, 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

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