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:

org.apache.hadoop.conf.Configurable, HiveIndexHandler

public class AggregateIndexHandler
extends CompactIndexHandler

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

Constructor Summary

AggregateIndexHandler()

Method Summary

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(Set<ReadEntity> inputs, Set<WriteEntity> outputs, List<FieldSchema> indexField, boolean partitioned, PartitionDesc indexTblPartDesc, String indexTableName, PartitionDesc baseTablePartDesc, String baseTableName, 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(Set<ReadEntity> inputs,
                                            Set<WriteEntity> outputs,
                                            List<FieldSchema> indexField,
                                            boolean partitioned,
                                            PartitionDesc indexTblPartDesc,
                                            String indexTableName,
                                            PartitionDesc baseTablePartDesc,
                                            String baseTableName,
                                            String dbName)

Overrides:

getIndexBuilderMapRedTask in class CompactIndexHandler