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