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,
boolean checkHashTableEntries)
Obtain big table position for join.
|
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, boolean checkHashTableEntries) throws SemanticException
joinOp
- join operatorcontext
- optimization contextbuckets
- bucket count for Bucket Map Join conversion consideration or reduce count
for Dynamic Hash Join conversion considerationskipJoinTypeChecks
- whether to skip join type checkingmaxSize
- size threshold for Map Join conversioncheckHashTableEntries
- whether to check threshold for distinct keys in hash table for Map JoinSemanticException
public MapJoinOperator convertJoinMapJoin(JoinOperator joinOp, OptimizeTezProcContext context, int bigTablePosition, boolean removeReduceSink) throws SemanticException
SemanticException
Copyright © 2021 The Apache Software Foundation. All rights reserved.