org.apache.hadoop.hive.ql.ppd

Class OpProcFactory.DefaultPPD

java.lang.Object

org.apache.hadoop.hive.ql.ppd.OpProcFactory.DefaultPPD

All Implemented Interfaces:

NodeProcessor

Direct Known Subclasses:

OpProcFactory.FilterPPD, OpProcFactory.JoinPPD, OpProcFactory.LateralViewForwardPPD, OpProcFactory.ReduceSinkPPD, OpProcFactory.ScriptPPD, OpProcFactory.TableScanPPD, OpProcFactory.UDTFPPD

Enclosing class:

OpProcFactory

public static class OpProcFactory.DefaultPPD
extends java.lang.Object
implements NodeProcessor

Default processor which just merges its children.

Constructor Summary

Constructors

Constructor and Description
DefaultPPD()

Method Summary

Modifier and Type	Method and Description
protected void	logExpr(Node nd, ExprWalkerInfo ewi)
protected ExprWalkerInfo	mergeChildrenPred(Node nd, OpWalkerInfo owi, java.util.Set<java.lang.String> excludedAliases, boolean ignoreAliases)
protected boolean	mergeWithChildrenPred(Node nd, OpWalkerInfo owi, ExprWalkerInfo ewi, java.util.Set<java.lang.String> aliases, boolean ignoreAliases) Take current operators pushdown predicates and merges them with children's pushdown predicates.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultPPD

public DefaultPPD()

Method Detail

process

public java.lang.Object process(Node nd,
                                java.util.Stack<Node> stack,
                                NodeProcessorCtx procCtx,
                                java.lang.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

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

logExpr

protected void logExpr(Node nd,
                       ExprWalkerInfo ewi)

Parameters:

nd -

ewi -

mergeWithChildrenPred

protected boolean mergeWithChildrenPred(Node nd,
                                        OpWalkerInfo owi,
                                        ExprWalkerInfo ewi,
                                        java.util.Set<java.lang.String> aliases,
                                        boolean ignoreAliases)
                                 throws SemanticException

Take current operators pushdown predicates and merges them with children's pushdown predicates.

Parameters:

nd - current operator

owi - operator context during this walk

ewi - pushdown predicates (part of expression walker info)

aliases - aliases that this operator can pushdown. null means that all aliases can be pushed down

ignoreAliases -

Throws:

SemanticException

mergeChildrenPred

protected ExprWalkerInfo mergeChildrenPred(Node nd,
                                           OpWalkerInfo owi,
                                           java.util.Set<java.lang.String> excludedAliases,
                                           boolean ignoreAliases)
                                    throws SemanticException

Throws:

SemanticException