org.apache.hadoop.hive.ql.optimizer
Class AbstractSMBJoinProc

java.lang.Object
  extended by org.apache.hadoop.hive.ql.optimizer.AbstractBucketJoinProc
      extended by org.apache.hadoop.hive.ql.optimizer.AbstractSMBJoinProc
All Implemented Interfaces:
NodeProcessor
Direct Known Subclasses:
SortedMergeBucketMapjoinProc, SortedMergeJoinProc

public abstract class AbstractSMBJoinProc
extends AbstractBucketJoinProc
implements NodeProcessor


Field Summary
 
Fields inherited from class org.apache.hadoop.hive.ql.optimizer.AbstractBucketJoinProc
pGraphContext
 
Constructor Summary
AbstractSMBJoinProc()
           
AbstractSMBJoinProc(ParseContext pctx)
           
 
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 org.apache.hadoop.hive.ql.optimizer.AbstractBucketJoinProc
canConvertMapJoinToBucketMapJoin, checkConvertBucketMapJoin, convertMapJoinToBucketMapJoin, toColumns
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractSMBJoinProc

public AbstractSMBJoinProc(ParseContext pctx)

AbstractSMBJoinProc

public AbstractSMBJoinProc()
Method Detail

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 process
procCtx - operator processor context
nodeOutputs - 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