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

Nested Classes

Modifier and Type	Class and Description
static class	HBaseTableInputFormat.HBaseTableIFBuilder
protected class	HBaseTableInputFormat.HBaseTableRecordReader

Field Summary

Fields

Modifier and Type	Field and Description
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_BATCHSIZE, 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, SHUFFLE_MAPS

Fields inherited from class org.apache.hadoop.hbase.mapreduce.TableInputFormatBase

INPUT_AUTOBALANCE_MAXSKEWRATIO, MAPREDUCE_INPUT_AUTOBALANCE, TABLE_ROW_TEXTKEY

Constructor Summary

Constructors

Modifier	Constructor and Description
	HBaseTableInputFormat()
protected	HBaseTableInputFormat(long limit, byte[] gt, byte[] gte, byte[] lt, byte[] lte)

Method Summary

Modifier and Type	Method and Description
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context)

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

addColumns, configureSplitTable, getConf, getStartEndKeys, initialize, setConf

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

calculateRebalancedSplits, closeTable, createRecordReader, getAdmin, getHTable, getRegionLocator, getScan, getSplitKey, getTable, includeRegionInSplit, initializeTable, reverseDNS, 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.TableInputFormat

Throws:

IOException