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

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	l4j

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

mrwork, pathToPartitionInfo

Constructor Summary

Constructors

Constructor and Description
HiveIndexedInputFormat()
HiveIndexedInputFormat(String indexFileName)

Method Summary

Methods

Modifier and Type	Method and Description
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, getPartitionDescFromPath, getRecordReader, init, pushFilters, pushProjectionsAndFilters, pushProjectionsAndFilters

Methods inherited from class java.lang.Object

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