org.apache.hadoop.hive.ql.optimizer
Class AbstractSMBJoinProc
java.lang.Object
org.apache.hadoop.hive.ql.optimizer.AbstractBucketJoinProc
org.apache.hadoop.hive.ql.optimizer.AbstractSMBJoinProc
- All Implemented Interfaces:
- NodeProcessor
- Direct Known Subclasses:
- SortedMergeBucketMapjoinProc, SortedMergeJoinProc
public abstract class AbstractSMBJoinProc
- extends AbstractBucketJoinProc
- implements NodeProcessor
Method Summary |
protected boolean |
canConvertBucketMapJoinToSMBJoin(MapJoinOperator mapJoinOp,
Stack<Node> stack,
SortBucketJoinProcCtx smbJoinContext,
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 Object |
process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
Generic process for all ops that don't have specific implementations. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AbstractSMBJoinProc
public AbstractSMBJoinProc(ParseContext pctx)
AbstractSMBJoinProc
public AbstractSMBJoinProc()
process
public abstract Object process(Node nd,
Stack<Node> stack,
NodeProcessorCtx procCtx,
Object... nodeOutputs)
throws SemanticException
- Description copied from interface:
NodeProcessor
- Generic process for all ops that don't have specific implementations.
- Specified by:
process
in interface NodeProcessor
- Specified by:
process
in class AbstractBucketJoinProc
- Parameters:
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walk
- Returns:
- Object to be returned by the process call
- Throws:
SemanticException
canConvertBucketMapJoinToSMBJoin
protected boolean canConvertBucketMapJoinToSMBJoin(MapJoinOperator mapJoinOp,
Stack<Node> stack,
SortBucketJoinProcCtx smbJoinContext,
Object... nodeOutputs)
throws SemanticException
- Throws:
SemanticException
convertBucketMapJoinToSMBJoin
protected SMBMapJoinOperator convertBucketMapJoinToSMBJoin(MapJoinOperator mapJoinOp,
SortBucketJoinProcCtx smbJoinContext,
ParseContext parseContext)
checkConvertJoinToSMBJoin
protected boolean checkConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext,
ParseContext pGraphContext)
throws SemanticException
- Throws:
SemanticException
canConvertJoinToSMBJoin
protected boolean canConvertJoinToSMBJoin(JoinOperator joinOperator,
SortBucketJoinProcCtx smbJoinContext,
ParseContext pGraphContext)
throws SemanticException
- Throws:
SemanticException
canConvertJoinToBucketMapJoin
protected boolean canConvertJoinToBucketMapJoin(JoinOperator joinOp,
ParseContext pGraphContext,
SortBucketJoinProcCtx context)
throws SemanticException
- Throws:
SemanticException
convertJoinToBucketMapJoin
protected MapJoinOperator convertJoinToBucketMapJoin(JoinOperator joinOp,
SortBucketJoinProcCtx joinContext,
ParseContext parseContext)
throws SemanticException
- Throws:
SemanticException
convertJoinToSMBJoin
protected void convertJoinToSMBJoin(JoinOperator joinOp,
SortBucketJoinProcCtx smbJoinContext,
ParseContext parseContext)
throws SemanticException
- Throws:
SemanticException
Copyright © 2012 The Apache Software Foundation