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

HiveHBaseTableInputFormat()

Method Summary

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, getScan, getSplits, setScan

Methods inherited from class java.lang.Object

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