org.apache.pig.pen
Class IllustratorAttacher

java.lang.Object
  org.apache.pig.impl.plan.PlanVisitor<PhysicalOperator,PhysicalPlan>
      org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhyPlanVisitor
          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