org.apache.hadoop.hive.ql.optimizer.index
Class RewriteQueryUsingAggregateIndexCtx

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.index.RewriteQueryUsingAggregateIndexCtx

All Implemented Interfaces:

NodeProcessorCtx

public final class RewriteQueryUsingAggregateIndexCtx
extends Object
implements NodeProcessorCtx

RewriteQueryUsingAggregateIndexCtx class stores the context for the RewriteQueryUsingAggregateIndex used to rewrite operator plan with index table instead of base table.

Method Summary

String	getAggregateFunction()
ExprNodeColumnDesc	getAggrExprNode()
String	getBaseTableName()
GenericUDAFEvaluator	getEval()
Hive	getHiveDb()
String	getIndexName()
static RewriteQueryUsingAggregateIndexCtx	getInstance(ParseContext parseContext, Hive hiveDb, String indexTableName, String baseTableName, String aggregateFunction)
Map<Operator<? extends OperatorDesc>,OpParseContext>	getOpc()
ParseContext	getParseContext()
void	invokeRewriteQueryProc(Operator<? extends OperatorDesc> topOp) Walk the original operator tree using the DefaultGraphWalker using the rules.
void	setAggrExprNode(ExprNodeColumnDesc aggrExprNode)
void	setEval(GenericUDAFEvaluator eval)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static RewriteQueryUsingAggregateIndexCtx getInstance(ParseContext parseContext,
                                                             Hive hiveDb,
                                                             String indexTableName,
                                                             String baseTableName,
                                                             String aggregateFunction)

getOpc

public Map<Operator<? extends OperatorDesc>,OpParseContext> getOpc()

getParseContext

public ParseContext getParseContext()

getHiveDb

public Hive getHiveDb()

getIndexName

public String getIndexName()

getEval

public GenericUDAFEvaluator getEval()

setEval

public void setEval(GenericUDAFEvaluator eval)

setAggrExprNode

public void setAggrExprNode(ExprNodeColumnDesc aggrExprNode)

getAggrExprNode

public ExprNodeColumnDesc getAggrExprNode()

invokeRewriteQueryProc

public void invokeRewriteQueryProc(Operator<? extends OperatorDesc> topOp)
                            throws SemanticException

Walk the original operator tree using the DefaultGraphWalker using the rules. Each of the rules invoke respective methods from the RewriteQueryUsingAggregateIndex to rewrite the original query using aggregate index.

Parameters:

topOp -

Throws:

SemanticException

getBaseTableName

public String getBaseTableName()

getAggregateFunction

public String getAggregateFunction()