org.apache.hadoop.hive.ql.optimizer.physical
Class BucketingSortingOpProcFactory.MultiGroupByInferrer
java.lang.Object
org.apache.hadoop.hive.ql.optimizer.physical.BucketingSortingOpProcFactory.DefaultInferrer
org.apache.hadoop.hive.ql.optimizer.physical.BucketingSortingOpProcFactory.GroupByInferrer
org.apache.hadoop.hive.ql.optimizer.physical.BucketingSortingOpProcFactory.MultiGroupByInferrer
- All Implemented Interfaces:
- NodeProcessor
- Enclosing class:
- BucketingSortingOpProcFactory
public static class BucketingSortingOpProcFactory.MultiGroupByInferrer
- extends BucketingSortingOpProcFactory.GroupByInferrer
- implements NodeProcessor
Processor for GroupByOperator, the special case where it follows a ForwardOperator
There is a multi group by optimization which puts multiple group by operators in a
reducer when they share the same keys and are part of a multi insert query.
In this case the tree should look like
Group By Operator
/
ReduceSinkOperator - ForwardOperator --- ...
\
GroupByOperator
BucketingSortingOpProcFactory.MultiGroupByInferrer
public BucketingSortingOpProcFactory.MultiGroupByInferrer()
process
public Object process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
throws SemanticException
- Description copied from interface:
NodeProcessor
- Generic process for all ops that don't have specific implementations.
- Specified by:
process
in interface NodeProcessor
- Overrides:
process
in class BucketingSortingOpProcFactory.GroupByInferrer
- Parameters:
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walk
- Returns:
- Object to be returned by the process call
- Throws:
SemanticException
Copyright © 2014 The Apache Software Foundation. All rights reserved.