org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Class PhyPlanSetter

java.lang.Object

org.apache.pig.impl.plan.PlanVisitor<PhysicalOperator,PhysicalPlan>

org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhyPlanVisitor

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PhyPlanSetter

public class PhyPlanSetter
extends PhyPlanVisitor

Sets the parent plan for all Physical Operators. Note: parentPlan is a bit of a misnomer. We actually want all the operators to point to the same plan - not necessarily the one they're a member of.

Field Summary

Fields inherited from class org.apache.pig.impl.plan.PlanVisitor

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
PhyPlanSetter(PhysicalPlan plan)

Method Summary

Methods

Modifier and Type	Method and Description
void	visit(PhysicalOperator op)
void	visitAdd(Add add)
void	visitAnd(POAnd and)
void	visitBinCond(POBinCond binCond)
void	visitCast(POCast cast)
void	visitCollectedGroup(POCollectedGroup mg)
void	visitComparisonFunc(POUserComparisonFunc compFunc)
void	visitConstant(ConstantExpression cnst)
void	visitDemux(PODemux demux)
void	visitDistinct(PODistinct distinct)
void	visitDivide(Divide dv)
void	visitEqualTo(EqualToExpr eq)
void	visitFilter(POFilter fl)
void	visitFRJoin(POFRJoin join)
void	visitGlobalRearrange(POGlobalRearrange gr)
void	visitGreaterThan(GreaterThanExpr grt)
void	visitGTOrEqual(GTOrEqualToExpr gte)
void	visitIsNull(POIsNull isNull)
void	visitLessThan(LessThanExpr lt)
void	visitLimit(POLimit lim)
void	visitLoad(POLoad ld)
void	visitLocalRearrange(POLocalRearrange lr)
void	visitLTOrEqual(LTOrEqualToExpr lte)
void	visitMapLookUp(POMapLookUp mapLookUp)
void	visitMergeCoGroup(POMergeCogroup mergeCoGrp)
void	visitMergeJoin(POMergeJoin join)
void	visitMod(Mod mod)
void	visitMultiply(Multiply mul)
void	visitNative(PONative nt)
void	visitNegative(PONegative negative)
void	visitNot(PONot not)
void	visitNotEqualTo(NotEqualToExpr eq)
void	visitOr(POOr or)
void	visitPackage(POPackage pkg)
void	visitPartialAgg(POPartialAgg poPartialAgg)
void	visitPOForEach(POForEach nfe)
void	visitPoissonSample(POPoissonSample poissonSample)
void	visitPOOptimizedForEach(POOptimizedForEach optimizedForEach)
void	visitPreCombinerLocalRearrange(POPreCombinerLocalRearrange preCombinerLocalRearrange)
void	visitProject(POProject proj)
void	visitRank(PORank rank)
void	visitRegexp(PORegexp re)
void	visitReservoirSample(POReservoirSample reservoirSample)
void	visitSkewedJoin(POSkewedJoin join)
void	visitSort(POSort sort)
void	visitSplit(POSplit spl)
void	visitStore(POStore st)
void	visitStream(POStream stream)
void	visitSubtract(Subtract sub)
void	visitUnion(POUnion un)
void	visitUserFunc(POUserFunc userFunc)

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhyPlanVisitor

visitCounter, visitCross, visitPartitionRearrange

Methods inherited from class org.apache.pig.impl.plan.PlanVisitor

getPlan, popWalker, pushWalker, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

PhyPlanSetter

public PhyPlanSetter(PhysicalPlan plan)

Method Detail

visit

public void visit(PhysicalOperator op)

Overrides:

visit in class PhyPlanVisitor

visitLoad

public void visitLoad(POLoad ld)
               throws VisitorException

Overrides:

visitLoad in class PhyPlanVisitor

Throws:

VisitorException

visitNative

public void visitNative(PONative nt)
                 throws VisitorException

Overrides:

visitNative in class PhyPlanVisitor

Throws:

VisitorException

visitStore

public void visitStore(POStore st)
                throws VisitorException

Overrides:

visitStore in class PhyPlanVisitor

Throws:

VisitorException

visitFilter

public void visitFilter(POFilter fl)
                 throws VisitorException

Overrides:

visitFilter in class PhyPlanVisitor

Throws:

VisitorException

visitLocalRearrange

public void visitLocalRearrange(POLocalRearrange lr)
                         throws VisitorException

Overrides:

visitLocalRearrange in class PhyPlanVisitor

Throws:

VisitorException

visitCollectedGroup

public void visitCollectedGroup(POCollectedGroup mg)
                         throws VisitorException

Overrides:

visitCollectedGroup in class PhyPlanVisitor

Throws:

VisitorException

visitGlobalRearrange

public void visitGlobalRearrange(POGlobalRearrange gr)
                          throws VisitorException

Overrides:

visitGlobalRearrange in class PhyPlanVisitor

Throws:

VisitorException

visitPackage

public void visitPackage(POPackage pkg)
                  throws VisitorException

Overrides:

visitPackage in class PhyPlanVisitor

Throws:

VisitorException

visitPOForEach

public void visitPOForEach(POForEach nfe)
                    throws VisitorException

Overrides:

visitPOForEach in class PhyPlanVisitor

Throws:

VisitorException

visitUnion

public void visitUnion(POUnion un)
                throws VisitorException

Overrides:

visitUnion in class PhyPlanVisitor

Throws:

VisitorException

visitSplit

public void visitSplit(POSplit spl)
                throws VisitorException

Overrides:

visitSplit in class PhyPlanVisitor

Throws:

VisitorException

visitDemux

public void visitDemux(PODemux demux)
                throws VisitorException

Overrides:

visitDemux in class PhyPlanVisitor

Throws:

VisitorException

visitDistinct

public void visitDistinct(PODistinct distinct)
                   throws VisitorException

Overrides:

visitDistinct in class PhyPlanVisitor

Throws:

VisitorException

visitSort

public void visitSort(POSort sort)
               throws VisitorException

Overrides:

visitSort in class PhyPlanVisitor

Throws:

VisitorException

visitRank

public void visitRank(PORank rank)
               throws VisitorException

Overrides:

visitRank in class PhyPlanVisitor

Throws:

VisitorException

visitConstant

public void visitConstant(ConstantExpression cnst)
                   throws VisitorException

Overrides:

visitConstant in class PhyPlanVisitor

Throws:

VisitorException

visitProject

public void visitProject(POProject proj)
                  throws VisitorException

Overrides:

visitProject in class PhyPlanVisitor

Throws:

VisitorException

visitGreaterThan

public void visitGreaterThan(GreaterThanExpr grt)
                      throws VisitorException

Overrides:

visitGreaterThan in class PhyPlanVisitor

Throws:

VisitorException

visitLessThan

public void visitLessThan(LessThanExpr lt)
                   throws VisitorException

Overrides:

visitLessThan in class PhyPlanVisitor

Throws:

VisitorException

visitGTOrEqual

public void visitGTOrEqual(GTOrEqualToExpr gte)
                    throws VisitorException

Overrides:

visitGTOrEqual in class PhyPlanVisitor

Throws:

VisitorException

visitLTOrEqual

public void visitLTOrEqual(LTOrEqualToExpr lte)
                    throws VisitorException

Overrides:

visitLTOrEqual in class PhyPlanVisitor

Throws:

VisitorException

visitEqualTo

public void visitEqualTo(EqualToExpr eq)
                  throws VisitorException

Overrides:

visitEqualTo in class PhyPlanVisitor

Throws:

VisitorException

visitNotEqualTo

public void visitNotEqualTo(NotEqualToExpr eq)
                     throws VisitorException

Overrides:

visitNotEqualTo in class PhyPlanVisitor

Throws:

VisitorException

visitRegexp

public void visitRegexp(PORegexp re)
                 throws VisitorException

Overrides:

visitRegexp in class PhyPlanVisitor

Throws:

VisitorException

visitIsNull

public void visitIsNull(POIsNull isNull)
                 throws VisitorException

Overrides:

visitIsNull in class PhyPlanVisitor

Throws:

VisitorException

visitAdd

public void visitAdd(Add add)
              throws VisitorException

Overrides:

visitAdd in class PhyPlanVisitor

Throws:

VisitorException

visitSubtract

public void visitSubtract(Subtract sub)
                   throws VisitorException

Overrides:

visitSubtract in class PhyPlanVisitor

Throws:

VisitorException

visitMultiply

public void visitMultiply(Multiply mul)
                   throws VisitorException

Overrides:

visitMultiply in class PhyPlanVisitor

Throws:

VisitorException

visitDivide

public void visitDivide(Divide dv)
                 throws VisitorException

Overrides:

visitDivide in class PhyPlanVisitor

Throws:

VisitorException

visitMod

public void visitMod(Mod mod)
              throws VisitorException

Overrides:

visitMod in class PhyPlanVisitor

Throws:

VisitorException

visitAnd

public void visitAnd(POAnd and)
              throws VisitorException

Overrides:

visitAnd in class PhyPlanVisitor

Throws:

VisitorException

visitOr

public void visitOr(POOr or)
             throws VisitorException

Overrides:

visitOr in class PhyPlanVisitor

Throws:

VisitorException

visitNot

public void visitNot(PONot not)
              throws VisitorException

Overrides:

visitNot in class PhyPlanVisitor

Throws:

VisitorException

visitBinCond

public void visitBinCond(POBinCond binCond)

Overrides:

visitBinCond in class PhyPlanVisitor

visitNegative

public void visitNegative(PONegative negative)

Overrides:

visitNegative in class PhyPlanVisitor

visitUserFunc

public void visitUserFunc(POUserFunc userFunc)
                   throws VisitorException

Overrides:

visitUserFunc in class PhyPlanVisitor

Throws:

VisitorException

visitComparisonFunc

public void visitComparisonFunc(POUserComparisonFunc compFunc)
                         throws VisitorException

Overrides:

visitComparisonFunc in class PhyPlanVisitor

Throws:

VisitorException

visitMapLookUp

public void visitMapLookUp(POMapLookUp mapLookUp)

Overrides:

visitMapLookUp in class PhyPlanVisitor

visitCast

public void visitCast(POCast cast)

Overrides:

visitCast in class PhyPlanVisitor

visitLimit

public void visitLimit(POLimit lim)
                throws VisitorException

Overrides:

visitLimit in class PhyPlanVisitor

Throws:

VisitorException

visitFRJoin

public void visitFRJoin(POFRJoin join)
                 throws VisitorException

Overrides:

visitFRJoin in class PhyPlanVisitor

Throws:

VisitorException

visitMergeJoin

public void visitMergeJoin(POMergeJoin join)
                    throws VisitorException

Overrides:

visitMergeJoin in class PhyPlanVisitor

Throws:

VisitorException

visitSkewedJoin

public void visitSkewedJoin(POSkewedJoin join)
                     throws VisitorException

Overrides:

visitSkewedJoin in class PhyPlanVisitor

Throws:

VisitorException

visitStream

public void visitStream(POStream stream)
                 throws VisitorException

Overrides:

visitStream in class PhyPlanVisitor

Throws:

VisitorException

visitPartialAgg

public void visitPartialAgg(POPartialAgg poPartialAgg)
                     throws VisitorException

Overrides:

visitPartialAgg in class PhyPlanVisitor

Throws:

VisitorException

visitPOOptimizedForEach

public void visitPOOptimizedForEach(POOptimizedForEach optimizedForEach)
                             throws VisitorException

Overrides:

visitPOOptimizedForEach in class PhyPlanVisitor

Throws:

VisitorException

visitPreCombinerLocalRearrange

public void visitPreCombinerLocalRearrange(POPreCombinerLocalRearrange preCombinerLocalRearrange)
                                    throws VisitorException

Overrides:

visitPreCombinerLocalRearrange in class PhyPlanVisitor

Throws:

VisitorException

visitMergeCoGroup

public void visitMergeCoGroup(POMergeCogroup mergeCoGrp)
                       throws VisitorException

Overrides:

visitMergeCoGroup in class PhyPlanVisitor

Throws:

VisitorException

visitReservoirSample

public void visitReservoirSample(POReservoirSample reservoirSample)
                          throws VisitorException

Overrides:

visitReservoirSample in class PhyPlanVisitor

Throws:

VisitorException

visitPoissonSample

public void visitPoissonSample(POPoissonSample poissonSample)
                        throws VisitorException

Overrides:

visitPoissonSample in class PhyPlanVisitor

Throws:

VisitorException