public abstract class AbstractBucketJoinProc extends java.lang.Object implements NodeProcessor
Modifier and Type | Field and Description |
---|---|
protected ParseContext |
pGraphContext |
Constructor and Description |
---|
AbstractBucketJoinProc() |
AbstractBucketJoinProc(ParseContext pGraphContext) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
canConvertMapJoinToBucketMapJoin(MapJoinOperator mapJoinOp,
ParseContext pGraphContext,
BucketJoinProcCtx context) |
protected boolean |
checkConvertBucketMapJoin(ParseContext pGraphContext,
BucketJoinProcCtx context,
QBJoinTree joinCtx,
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> keysMap,
java.lang.String baseBigAlias,
java.util.List<java.lang.String> joinAliases) |
protected void |
convertMapJoinToBucketMapJoin(MapJoinOperator mapJoinOp,
BucketJoinProcCtx context) |
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.
|
java.util.List<java.lang.String> |
toColumns(java.util.List<ExprNodeDesc> keys) |
protected ParseContext pGraphContext
public AbstractBucketJoinProc(ParseContext pGraphContext)
public AbstractBucketJoinProc()
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
nd
- operator to processprocCtx
- operator processor contextnodeOutputs
- A variable argument list of outputs from other nodes in the walkSemanticException
protected boolean canConvertMapJoinToBucketMapJoin(MapJoinOperator mapJoinOp, ParseContext pGraphContext, BucketJoinProcCtx context) throws SemanticException
SemanticException
protected boolean checkConvertBucketMapJoin(ParseContext pGraphContext, BucketJoinProcCtx context, QBJoinTree joinCtx, java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> keysMap, java.lang.String baseBigAlias, java.util.List<java.lang.String> joinAliases) throws SemanticException
SemanticException
protected void convertMapJoinToBucketMapJoin(MapJoinOperator mapJoinOp, BucketJoinProcCtx context) throws SemanticException
SemanticException
public java.util.List<java.lang.String> toColumns(java.util.List<ExprNodeDesc> keys)
Copyright © 2012 The Apache Software Foundation