org.apache.pig.backend.hadoop.executionengine.tez.plan

Class TezPOPackageAnnotator.LoRearrangeDiscoverer

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.tez.plan.TezPOPackageAnnotator.LoRearrangeDiscoverer

Enclosing class:

TezPOPackageAnnotator

public static class TezPOPackageAnnotator.LoRearrangeDiscoverer
extends PhyPlanVisitor

Physical Plan visitor which tries to get the LocalRearrange(s) present in the plan (if any) and annotate the POPackage given to it with the information in the LocalRearrange (regarding columns in the "value" present in the "key")

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
TezPOPackageAnnotator.LoRearrangeDiscoverer(PhysicalPlan predPlan, TezOperator predTezOpVertexGrp, TezOperator pkgTezOp, POPackage pkg)

Method Summary

Methods

Modifier and Type	Method and Description
int	getLoRearrangeFound()
void	visitLocalRearrange(POLocalRearrange lrearrange)
void	visitSplit(POSplit spl)

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

visit, visitAdd, visitAnd, visitBinCond, visitCast, visitCollectedGroup, visitComparisonFunc, visitConstant, visitCounter, visitCross, visitDemux, visitDistinct, visitDivide, visitEqualTo, visitFilter, visitFRJoin, visitGlobalRearrange, visitGreaterThan, visitGTOrEqual, visitIsNull, visitLessThan, visitLimit, visitLoad, visitLTOrEqual, visitMapLookUp, visitMergeCoGroup, visitMergeJoin, visitMod, visitMultiply, visitNative, visitNegative, visitNot, visitNotEqualTo, visitOr, visitPackage, visitPartialAgg, visitPartitionRearrange, visitPOForEach, visitPoissonSample, visitPOOptimizedForEach, visitPreCombinerLocalRearrange, visitProject, visitRank, visitRegexp, visitReservoirSample, visitSkewedJoin, visitSort, visitStore, visitStream, visitSubtract, visitUnion, visitUserFunc

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

TezPOPackageAnnotator.LoRearrangeDiscoverer

public TezPOPackageAnnotator.LoRearrangeDiscoverer(PhysicalPlan predPlan,
                                           TezOperator predTezOpVertexGrp,
                                           TezOperator pkgTezOp,
                                           POPackage pkg)

Method Detail

visitSplit

public void visitSplit(POSplit spl)
                throws VisitorException

Overrides:

visitSplit in class PhyPlanVisitor

Throws:

VisitorException

visitLocalRearrange

public void visitLocalRearrange(POLocalRearrange lrearrange)
                         throws VisitorException

Overrides:

visitLocalRearrange in class PhyPlanVisitor

Throws:

VisitorException

getLoRearrangeFound

public int getLoRearrangeFound()

Returns:

the loRearrangeFound