public abstract class TableBasedIndexHandler extends AbstractIndexHandler
Modifier and Type | Field and Description |
---|---|
protected Configuration |
configuration |
Constructor and Description |
---|
TableBasedIndexHandler() |
Modifier and Type | Method and Description |
---|---|
java.util.List<Task<?>> |
generateIndexBuildTaskList(Table baseTbl,
Index index,
java.util.List<Partition> indexTblPartitions,
java.util.List<Partition> baseTblPartitions,
Table indexTbl,
java.util.Set<ReadEntity> inputs,
java.util.Set<WriteEntity> outputs)
Requests that the handler generate a plan for building the index; the plan
should read the base table and write out the index representation.
|
Configuration |
getConf() |
protected abstract 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) |
protected java.util.List<java.lang.String> |
getPartKVPairStringArray(java.util.LinkedHashMap<java.lang.String,java.lang.String> partSpec) |
void |
setConf(Configuration conf) |
boolean |
usesIndexTable()
Determines whether this handler implements indexes by creating an index
table.
|
checkQuerySize, generateIndexQuery, getColumnNames
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
analyzeIndexDefinition, generateIndexQuery
public java.util.List<Task<?>> generateIndexBuildTaskList(Table baseTbl, Index index, java.util.List<Partition> indexTblPartitions, java.util.List<Partition> baseTblPartitions, Table indexTbl, java.util.Set<ReadEntity> inputs, java.util.Set<WriteEntity> outputs) throws HiveException
HiveIndexHandler
baseTbl
- the definition of the table being indexedindex
- the definition of the indexbaseTblPartitions
- list of base table partitions with each element mirrors to the
corresponding one in indexTblPartitionsindexTbl
- the definition of the index table, or null if usesIndexTable()
returns nullinputs
- inputs for hooks, supplemental outputs going
along with the return valueoutputs
- outputs for hooks, supplemental outputs going
along with the return valueHiveException
- if plan generation failsprotected abstract 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) throws HiveException
HiveException
protected java.util.List<java.lang.String> getPartKVPairStringArray(java.util.LinkedHashMap<java.lang.String,java.lang.String> partSpec)
public boolean usesIndexTable()
HiveIndexHandler
public Configuration getConf()
public void setConf(Configuration conf)
Copyright © 2012 The Apache Software Foundation