org.apache.pig.pen
Class IllustratorAttacher

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.pen.IllustratorAttacher

public class IllustratorAttacher
extends PhyPlanVisitor

The class used to (re)attach illustrators to physical operators


Field Summary
 
Fields inherited from class org.apache.pig.impl.plan.PlanVisitor
mCurrentWalker, mPlan
 
Constructor Summary
IllustratorAttacher(PhysicalPlan plan, LineageTracer lineage, int maxRecords, Map<POLoad,LogicalSchema> poLoadToSchemaMap, PigContext hadoopPigContext)
           
 
Method Summary
 Map<PhysicalOperator,DataBag> getDataMap()
           
 void revisit(PhysicalPlan plan)
          revisit an enhanced physical plan from MR compilation
 void visitAnd(POAnd and)
           
 void visitBinCond(POBinCond binCond)
           
 void visitCast(POCast cast)
           
 void visitComparisonFunc(POUserComparisonFunc compFunc)
           
 void visitCounter(POCounter counter)
           
 void visitDemux(PODemux demux)
           
 void visitDistinct(PODistinct distinct)
           
 void visitEqualTo(EqualToExpr eq)
           
 void visitFilter(POFilter fl)
           
 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 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 visitProject(POProject proj)
           
 void visitRank(PORank rank)
           
 void visitRegexp(PORegexp re)
           
 void visitSort(POSort sort)
           
 void visitSplit(POSplit spl)
           
 void visitStore(POStore st)
           
 void visitStream(POStream stream)
           
 void visitUnion(POUnion un)
           
 void visitUserFunc(POUserFunc userFunc)
           
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhyPlanVisitor
visitAdd, visitCollectedGroup, visitConstant, visitCross, visitDivide, visitFRJoin, visitGlobalRearrange, visitMergeCoGroup, visitMergeJoin, visitMod, visitMultiply, visitNative, visitPartialAgg, visitPartitionRearrange, visitPreCombinerLocalRearrange, visitSkewedJoin, visitSubtract
 
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

IllustratorAttacher

public IllustratorAttacher(PhysicalPlan plan,
                           LineageTracer lineage,
                           int maxRecords,
                           Map<POLoad,LogicalSchema> poLoadToSchemaMap,
                           PigContext hadoopPigContext)
                    throws VisitorException
Throws:
VisitorException
Method Detail

revisit

public void revisit(PhysicalPlan plan)
             throws VisitorException
revisit an enhanced physical plan from MR compilation

Parameters:
plan - a physical plan to be traversed
Throws:
VisitorException

getDataMap

public Map<PhysicalOperator,DataBag> getDataMap()

visitLoad

public void visitLoad(POLoad ld)
               throws VisitorException
Overrides:
visitLoad 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

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

visitCounter

public void visitCounter(POCounter counter)
                  throws VisitorException
Overrides:
visitCounter 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

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

visitStream

public void visitStream(POStream stream)
                 throws VisitorException
Overrides:
visitStream in class PhyPlanVisitor
Throws:
VisitorException

visitPOOptimizedForEach

public void visitPOOptimizedForEach(POOptimizedForEach optimizedForEach)
                             throws VisitorException
Overrides:
visitPOOptimizedForEach in class PhyPlanVisitor
Parameters:
optimizedForEach -
Throws:
VisitorException


Copyright © 2007-2012 The Apache Software Foundation