org.apache.hadoop.hive.hbase

Class HiveHBaseTableInputFormat

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.hive.hbase.HiveHBaseTableInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.hbase.io.ImmutableBytesWritable,ResultWritable>

public class HiveHBaseTableInputFormat
extends org.apache.hadoop.hbase.mapreduce.TableInputFormatBase
implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.hbase.io.ImmutableBytesWritable,ResultWritable>

HiveHBaseTableInputFormat implements InputFormat for HBase storage handler tables, decorating an underlying HBase TableInputFormat with extra Hive logic such as column pruning and filter pushdown.

Constructor Summary

Constructors

Constructor and Description
HiveHBaseTableInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,ResultWritable>	getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf jobConf, int numSplits)

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

createRecordReader, getHTable, getScan, getSplits, getStartEndKeys, includeRegionInSplit, reverseDNS, setHTable, setScan, setTableRecordReader

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveHBaseTableInputFormat

public HiveHBaseTableInputFormat()

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,ResultWritable> getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                                                                                      org.apache.hadoop.mapred.JobConf jobConf,
                                                                                                                      org.apache.hadoop.mapred.Reporter reporter)
                                                                                                                        throws IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.hbase.io.ImmutableBytesWritable,ResultWritable>

Throws:

IOException

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf jobConf,
                                              int numSplits)
                                                throws IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.hbase.io.ImmutableBytesWritable,ResultWritable>

Throws:

IOException