public class ConvertJoinMapJoin extends Object implements NodeProcessor
Constructor and Description |
---|
ConvertJoinMapJoin() |
Modifier and Type | Method and Description |
---|---|
MapJoinOperator |
convertJoinMapJoin(JoinOperator joinOp,
OptimizeTezProcContext context,
int bigTablePosition,
boolean removeReduceSink) |
int |
getMapJoinConversionPos(JoinOperator joinOp,
OptimizeTezProcContext context,
int buckets,
boolean skipJoinTypeChecks,
long maxSize) |
Object |
process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx, 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
public int getMapJoinConversionPos(JoinOperator joinOp, OptimizeTezProcContext context, int buckets, boolean skipJoinTypeChecks, long maxSize) throws SemanticException
SemanticException
public MapJoinOperator convertJoinMapJoin(JoinOperator joinOp, OptimizeTezProcContext context, int bigTablePosition, boolean removeReduceSink) throws SemanticException
SemanticException
Copyright © 2016 The Apache Software Foundation. All rights reserved.