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_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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
java.util.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 java.util.List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                                 throws java.io.IOException

Overrides:

getSplits in class org.apache.hadoop.hbase.mapreduce.TableInputFormatBase

Throws:

java.io.IOException