org.apache.hadoop.hive.ql.index
Class HiveIndexedInputFormat

java.lang.Object
  org.apache.hadoop.hive.ql.io.HiveInputFormat
      org.apache.hadoop.hive.ql.index.HiveIndexedInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat, org.apache.hadoop.mapred.JobConfigurable

Direct Known Subclasses:

HiveCompactIndexInputFormat

public class HiveIndexedInputFormat
extends HiveInputFormat

Input format for doing queries that use indexes. Uses a blockfilter file to specify the blocks to query.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.io.HiveInputFormat

HiveInputFormat.HiveInputSplit

Field Summary

static org.apache.commons.logging.Log

l4j

Fields inherited from class org.apache.hadoop.hive.ql.io.HiveInputFormat

CLASS_NAME, LOG

Constructor Summary

HiveIndexedInputFormat()

HiveIndexedInputFormat(String indexFileName)

Method Summary

org.apache.hadoop.mapred.InputSplit[]	doGetSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)
static List<String>	getIndexFiles(String indexFileStr)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)

Methods inherited from class org.apache.hadoop.hive.ql.io.HiveInputFormat

configure, getInputFormatFromCache, getRecordReader, pushFilters

Methods inherited from class java.lang.Object

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

Field Detail

l4j

public static final org.apache.commons.logging.Log l4j

Constructor Detail

HiveIndexedInputFormat

public HiveIndexedInputFormat()

HiveIndexedInputFormat

public HiveIndexedInputFormat(String indexFileName)

Method Detail

doGetSplits

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

Throws:

IOException

getIndexFiles

public static List<String> getIndexFiles(String indexFileStr)

getSplits

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

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat

Overrides:

getSplits in class HiveInputFormat

Throws:

IOException