org.apache.hadoop.hive.ql.index

Class AggregateIndexHandler

java.lang.Object

org.apache.hadoop.hive.ql.index.AbstractIndexHandler

org.apache.hadoop.hive.ql.index.TableBasedIndexHandler

org.apache.hadoop.hive.ql.index.compact.CompactIndexHandler

org.apache.hadoop.hive.ql.index.AggregateIndexHandler

All Implemented Interfaces:

HiveIndexHandler

public class AggregateIndexHandler
extends CompactIndexHandler

Index handler for indexes that have aggregate functions on indexed columns.

Constructor Summary

Constructors

Constructor and Description
AggregateIndexHandler()

Method Summary

Modifier and Type	Method and Description
void	analyzeIndexDefinition(Table baseTable, Index idx, Table indexTable) Requests that the handler validate an index definition and fill in additional information about its stored representation.
protected Task<?>	getIndexBuilderMapRedTask(java.util.Set<ReadEntity> inputs, java.util.Set<WriteEntity> outputs, java.util.List<FieldSchema> indexField, boolean partitioned, PartitionDesc indexTblPartDesc, java.lang.String indexTableName, PartitionDesc baseTablePartDesc, java.lang.String baseTableName, java.lang.String dbName)

Methods inherited from class org.apache.hadoop.hive.ql.index.compact.CompactIndexHandler

checkQuerySize, generateIndexQuery, usesIndexTable

Methods inherited from class org.apache.hadoop.hive.ql.index.TableBasedIndexHandler

generateIndexBuildTaskList, getConf, getPartKVPairStringArray, setConf

Methods inherited from class org.apache.hadoop.hive.ql.index.AbstractIndexHandler

generateIndexQuery, getColumnNames

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateIndexHandler

public AggregateIndexHandler()

Method Detail

analyzeIndexDefinition

public void analyzeIndexDefinition(Table baseTable,
                                   Index idx,
                                   Table indexTable)
                            throws HiveException

Description copied from interface: HiveIndexHandler

Requests that the handler validate an index definition and fill in additional information about its stored representation.

Specified by:

analyzeIndexDefinition in interface HiveIndexHandler

Overrides:

analyzeIndexDefinition in class CompactIndexHandler

Parameters:

baseTable - the definition of the table being indexed

idx - the definition of the index being created

indexTable - a partial definition of the index table to be used for storing the index representation, or null if usesIndexTable() returns false; the handler can augment the index's storage descriptor (e.g. with information about input/output format) and/or the index table's definition (typically with additional columns containing the index representation, e.g. pointers into HDFS).

Throws:

HiveException - if the index definition is invalid with respect to either the base table or the supplied index table definition

getIndexBuilderMapRedTask

protected Task<?> getIndexBuilderMapRedTask(java.util.Set<ReadEntity> inputs,
                                            java.util.Set<WriteEntity> outputs,
                                            java.util.List<FieldSchema> indexField,
                                            boolean partitioned,
                                            PartitionDesc indexTblPartDesc,
                                            java.lang.String indexTableName,
                                            PartitionDesc baseTablePartDesc,
                                            java.lang.String baseTableName,
                                            java.lang.String dbName)

Overrides:

getIndexBuilderMapRedTask in class CompactIndexHandler