org.apache.hadoop.hive.ql.optimizer
Class GenMRRedSink1
java.lang.Object
org.apache.hadoop.hive.ql.optimizer.GenMRRedSink1
- All Implemented Interfaces:
- NodeProcessor
public class GenMRRedSink1
- extends Object
- implements NodeProcessor
Processor for the rule - table scan followed by reduce sink.
GenMRRedSink1
public GenMRRedSink1()
process
public Object process(Node nd,
Stack<Node> stack,
NodeProcessorCtx opProcCtx,
Object... nodeOutputs)
throws SemanticException
- Reduce Sink encountered.
a) If we are seeing this RS for first time, we initialize plan corresponding to this RS.
b) If we are seeing this RS for second or later time then either query had a join in which
case we will merge this plan with earlier plan involving this RS or plan for this RS
needs to be split in two branches.
- Specified by:
process
in interface NodeProcessor
- Parameters:
nd
- the reduce sink operator encounteredopProcCtx
- 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.