public class GroupByOptimizer.SortGroupByProcessor extends java.lang.Object implements NodeProcessor
Modifier and Type | Field and Description |
---|---|
protected ParseContext |
pGraphContext |
Constructor and Description |
---|
SortGroupByProcessor(ParseContext pGraphContext) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkGroupByOperatorProcessed(GroupByOptimizer.GroupByOptimizerContext groupBySortOptimizerContext,
GroupByOperator groupByOp) |
protected GroupByOptimizer.GroupByOptimizerSortMatch |
checkSortGroupBy(java.util.Stack<Node> stack,
GroupByOperator groupByOp) |
protected void |
convertGroupByMapSideSortedGroupBy(HiveConf conf,
GroupByOperator groupByOp,
int depth) |
java.lang.Object |
process(Node nd,
java.util.Stack<Node> stack,
NodeProcessorCtx procCtx,
java.lang.Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
protected void |
processGroupBy(GroupByOptimizer.GroupByOptimizerContext ctx,
java.util.Stack<Node> stack,
GroupByOperator groupByOp,
int depth) |
protected ParseContext pGraphContext
public SortGroupByProcessor(ParseContext pGraphContext)
protected boolean checkGroupByOperatorProcessed(GroupByOptimizer.GroupByOptimizerContext groupBySortOptimizerContext, GroupByOperator groupByOp)
protected void processGroupBy(GroupByOptimizer.GroupByOptimizerContext ctx, java.util.Stack<Node> stack, GroupByOperator groupByOp, int depth) throws SemanticException
SemanticException
public java.lang.Object process(Node nd, java.util.Stack<Node> stack, NodeProcessorCtx procCtx, java.lang.Object... nodeOutputs) throws SemanticException
NodeProcessor
process
in interface NodeProcessor
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
protected GroupByOptimizer.GroupByOptimizerSortMatch checkSortGroupBy(java.util.Stack<Node> stack, GroupByOperator groupByOp) throws SemanticException
SemanticException
protected void convertGroupByMapSideSortedGroupBy(HiveConf conf, GroupByOperator groupByOp, int depth)
Copyright © 2012 The Apache Software Foundation