public class IllustratorAttacher extends PhyPlanVisitor
mCurrentWalker, mPlan
Constructor and Description |
---|
IllustratorAttacher(PhysicalPlan plan,
LineageTracer lineage,
int maxRecords,
Map<POLoad,LogicalSchema> poLoadToSchemaMap,
PigContext hadoopPigContext) |
visit, visitAdd, visitBroadcastSpark, visitCollectedGroup, visitConstant, visitCross, visitDivide, visitFRJoin, visitGlobalRearrange, visitMergeCoGroup, visitMergeJoin, visitMod, visitMultiply, visitNative, visitPartialAgg, visitPartitionRearrange, visitPoissonSample, visitPreCombinerLocalRearrange, visitReservoirSample, visitSkewedJoin, visitSubtract
getPlan, popWalker, pushWalker, visit
public IllustratorAttacher(PhysicalPlan plan, LineageTracer lineage, int maxRecords, Map<POLoad,LogicalSchema> poLoadToSchemaMap, PigContext hadoopPigContext) throws VisitorException
VisitorException
public void revisit(PhysicalPlan plan) throws VisitorException
plan
- a physical plan to be traversedVisitorException
public Map<PhysicalOperator,DataBag> getDataMap()
public void visitLoad(POLoad ld) throws VisitorException
visitLoad
in class PhyPlanVisitor
VisitorException
public void visitStore(POStore st) throws VisitorException
visitStore
in class PhyPlanVisitor
VisitorException
public void visitFilter(POFilter fl) throws VisitorException
visitFilter
in class PhyPlanVisitor
VisitorException
public void visitLocalRearrange(POLocalRearrange lr) throws VisitorException
visitLocalRearrange
in class PhyPlanVisitor
VisitorException
public void visitPackage(POPackage pkg) throws VisitorException
visitPackage
in class PhyPlanVisitor
VisitorException
public void visitPOForEach(POForEach nfe) throws VisitorException
visitPOForEach
in class PhyPlanVisitor
VisitorException
public void visitUnion(POUnion un) throws VisitorException
visitUnion
in class PhyPlanVisitor
VisitorException
public void visitSplit(POSplit spl) throws VisitorException
visitSplit
in class PhyPlanVisitor
VisitorException
public void visitDemux(PODemux demux) throws VisitorException
visitDemux
in class PhyPlanVisitor
VisitorException
public void visitDistinct(PODistinct distinct) throws VisitorException
visitDistinct
in class PhyPlanVisitor
VisitorException
public void visitSort(POSort sort) throws VisitorException
visitSort
in class PhyPlanVisitor
VisitorException
public void visitRank(PORank rank) throws VisitorException
visitRank
in class PhyPlanVisitor
VisitorException
public void visitCounter(POCounter counter) throws VisitorException
visitCounter
in class PhyPlanVisitor
VisitorException
public void visitProject(POProject proj) throws VisitorException
visitProject
in class PhyPlanVisitor
VisitorException
public void visitGreaterThan(GreaterThanExpr grt) throws VisitorException
visitGreaterThan
in class PhyPlanVisitor
VisitorException
public void visitLessThan(LessThanExpr lt) throws VisitorException
visitLessThan
in class PhyPlanVisitor
VisitorException
public void visitGTOrEqual(GTOrEqualToExpr gte) throws VisitorException
visitGTOrEqual
in class PhyPlanVisitor
VisitorException
public void visitLTOrEqual(LTOrEqualToExpr lte) throws VisitorException
visitLTOrEqual
in class PhyPlanVisitor
VisitorException
public void visitEqualTo(EqualToExpr eq) throws VisitorException
visitEqualTo
in class PhyPlanVisitor
VisitorException
public void visitNotEqualTo(NotEqualToExpr eq) throws VisitorException
visitNotEqualTo
in class PhyPlanVisitor
VisitorException
public void visitRegexp(PORegexp re) throws VisitorException
visitRegexp
in class PhyPlanVisitor
VisitorException
public void visitIsNull(POIsNull isNull) throws VisitorException
visitIsNull
in class PhyPlanVisitor
VisitorException
public void visitAnd(POAnd and) throws VisitorException
visitAnd
in class PhyPlanVisitor
VisitorException
public void visitOr(POOr or) throws VisitorException
visitOr
in class PhyPlanVisitor
VisitorException
public void visitNot(PONot not) throws VisitorException
visitNot
in class PhyPlanVisitor
VisitorException
public void visitBinCond(POBinCond binCond)
visitBinCond
in class PhyPlanVisitor
public void visitNegative(PONegative negative)
visitNegative
in class PhyPlanVisitor
public void visitUserFunc(POUserFunc userFunc) throws VisitorException
visitUserFunc
in class PhyPlanVisitor
VisitorException
public void visitComparisonFunc(POUserComparisonFunc compFunc) throws VisitorException
visitComparisonFunc
in class PhyPlanVisitor
VisitorException
public void visitMapLookUp(POMapLookUp mapLookUp)
visitMapLookUp
in class PhyPlanVisitor
public void visitCast(POCast cast)
visitCast
in class PhyPlanVisitor
public void visitLimit(POLimit lim) throws VisitorException
visitLimit
in class PhyPlanVisitor
VisitorException
public void visitStream(POStream stream) throws VisitorException
visitStream
in class PhyPlanVisitor
VisitorException
public void visitPOOptimizedForEach(POOptimizedForEach optimizedForEach) throws VisitorException
visitPOOptimizedForEach
in class PhyPlanVisitor
optimizedForEach
- VisitorException
Copyright © 2007-2017 The Apache Software Foundation