public class SparkSortMergeJoinOptimizer extends AbstractSMBJoinProc implements SemanticNodeProcessor
pGraphContext
Constructor and Description |
---|
SparkSortMergeJoinOptimizer() |
SparkSortMergeJoinOptimizer(ParseContext pctx) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
canConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext,
ParseContext pGraphContext,
Stack<Node> stack) |
protected SMBMapJoinOperator |
convertJoinToSMBJoinAndReturn(JoinOperator joinOp,
SortBucketJoinProcCtx smbJoinContext) |
Object |
process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations.
|
canConvertBucketMapJoinToSMBJoin, canConvertJoinToBucketMapJoin, canConvertJoinToSMBJoin, checkConvertJoinToSMBJoin, convertBucketMapJoinToSMBJoin, convertJoinToBucketMapJoin, convertJoinToSMBJoin
canConvertMapJoinToBucketMapJoin, checkConvertBucketMapJoin, convertMapJoinToBucketMapJoin, getBucketFilePathsOfPartition, toColumns
public SparkSortMergeJoinOptimizer(ParseContext pctx)
public SparkSortMergeJoinOptimizer()
public Object process(Node nd, Stack<Node> stack, NodeProcessorCtx procCtx, Object... nodeOutputs) throws SemanticException
SemanticNodeProcessor
process
in interface NodeProcessor
process
in interface SemanticNodeProcessor
process
in class AbstractSMBJoinProc
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
protected boolean canConvertJoinToSMBJoin(JoinOperator joinOperator, SortBucketJoinProcCtx smbJoinContext, ParseContext pGraphContext, Stack<Node> stack) throws SemanticException
SemanticException
protected SMBMapJoinOperator convertJoinToSMBJoinAndReturn(JoinOperator joinOp, SortBucketJoinProcCtx smbJoinContext) throws SemanticException
SemanticException
Copyright © 2022 The Apache Software Foundation. All rights reserved.