co.cask.cdap.hbase.wd

Class WdTableInputFormat

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

co.cask.cdap.hbase.wd.WdTableInputFormat

All Implemented Interfaces:

Configurable

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

Convert HBase tabular data into a format that is consumable by Map/Reduce with respect to row key distribution strategy

Field Summary

Fields

Modifier and Type	Field and Description
static String	ROW_KEY_DISTRIBUTOR_CLASS
static String	ROW_KEY_DISTRIBUTOR_PARAMS

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

Constructor Summary

Constructors

Constructor and Description
WdTableInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
List<InputSplit>	getSplits(JobContext context)
void	setConf(Configuration conf)

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

addColumns, getConf

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

ROW_KEY_DISTRIBUTOR_CLASS

public static final String ROW_KEY_DISTRIBUTOR_CLASS

See Also:

Constant Field Values

ROW_KEY_DISTRIBUTOR_PARAMS

public static final String ROW_KEY_DISTRIBUTOR_PARAMS

See Also:

Constant Field Values

Constructor Detail

WdTableInputFormat

public WdTableInputFormat()

Method Detail

setConf

public void setConf(Configuration conf)

Specified by:

setConf in interface Configurable

Overrides:

setConf in class org.apache.hadoop.hbase.mapreduce.TableInputFormat

getSplits

public List<InputSplit> getSplits(JobContext context)
                           throws IOException

Overrides:

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

Throws:

IOException