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 checkMapJoinThresholds)
Obtain big table position for join.
|
MemoryMonitorInfo |
getMemoryMonitorInfo(long maxSize,
HiveConf conf,
LlapClusterStateForCompile llapInfo) |
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 MemoryMonitorInfo getMemoryMonitorInfo(long maxSize, HiveConf conf, LlapClusterStateForCompile llapInfo)
public int getMapJoinConversionPos(JoinOperator joinOp, OptimizeTezProcContext context, int buckets, boolean skipJoinTypeChecks, long maxSize, boolean checkMapJoinThresholds) 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 conversioncheckMapJoinThresholds
- whether to check thresholds to convert to Map JoinSemanticException
public MapJoinOperator convertJoinMapJoin(JoinOperator joinOp, OptimizeTezProcContext context, int bigTablePosition, boolean removeReduceSink) throws SemanticException
SemanticException
Copyright © 2022 The Apache Software Foundation. All rights reserved.