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

java.lang.Object
  extended by org.apache.pig.impl.plan.PlanVisitor<PhysicalOperator,PhysicalPlan>
      extended by org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhyPlanVisitor
          extended by 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
PhyPlanSetter(PhysicalPlan plan)
           
 
Method Summary
 void visitAdd(Add add)
           
 void visitAnd(POAnd and)
           
 void visitBinCond(POBinCond binCond)
           
 void visitCast(POCast cast)
           
 void visitCollectedGroup(POCollectedGroup mg)
           
 void visitCombinerPackage(POCombinerPackage pkg)
           
 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 visitJoinPackage(POJoinPackage joinPackage)
           
 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 visitPOForEach(POForEach nfe)
           
 void visitPOOptimizedForEach(POOptimizedForEach optimizedForEach)
           
 void visitPreCombinerLocalRearrange(POPreCombinerLocalRearrange preCombinerLocalRearrange)
           
 void visitProject(POProject proj)
           
 void visitRegexp(PORegexp re)
           
 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
visitMultiQueryPackage, 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

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

visitCombinerPackage

public void visitCombinerPackage(POCombinerPackage pkg)
                          throws VisitorException
Overrides:
visitCombinerPackage 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

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

visitJoinPackage

public void visitJoinPackage(POJoinPackage joinPackage)
                      throws VisitorException
Overrides:
visitJoinPackage in class PhyPlanVisitor
Throws:
VisitorException

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

visitPOOptimizedForEach

public void visitPOOptimizedForEach(POOptimizedForEach optimizedForEach)
Overrides:
visitPOOptimizedForEach in class PhyPlanVisitor

visitPreCombinerLocalRearrange

public void visitPreCombinerLocalRearrange(POPreCombinerLocalRearrange preCombinerLocalRearrange)
Overrides:
visitPreCombinerLocalRearrange in class PhyPlanVisitor

visitMergeCoGroup

public void visitMergeCoGroup(POMergeCogroup mergeCoGrp)
                       throws VisitorException
Overrides:
visitMergeCoGroup in class PhyPlanVisitor
Throws:
VisitorException


Copyright © ${year} The Apache Software Foundation