public class ReduceSinkMapJoinProc extends Object implements NodeProcessor
Constructor and Description |
---|
ReduceSinkMapJoinProc() |
Modifier and Type | Method and Description |
---|---|
static BaseWork |
getMapJoinParentWork(GenTezProcContext context,
Operator<?> parentRS) |
Object |
process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procContext,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
static Object |
processReduceSinkToHashJoin(ReduceSinkOperator parentRS,
MapJoinOperator mapJoinOp,
GenTezProcContext context) |
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procContext, Object... nodeOutputs) throws SemanticException
NodeProcessor
process
in interface NodeProcessor
nd
- operator to processprocContext
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
public static BaseWork getMapJoinParentWork(GenTezProcContext context, Operator<?> parentRS)
public static Object processReduceSinkToHashJoin(ReduceSinkOperator parentRS, MapJoinOperator mapJoinOp, GenTezProcContext context) throws SemanticException
SemanticException
Copyright © 2016 The Apache Software Foundation. All rights reserved.