org.apache.pig.backend.hadoop.executionengine.util

Class CombinerOptimizerUtil.DistinctPatcher

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.util.CombinerOptimizerUtil.DistinctPatcher

Enclosing class:

CombinerOptimizerUtil

public static class CombinerOptimizerUtil.DistinctPatcher
extends PhyPlanVisitor

A visitor to replace Project[bag][*] | |---PODistinct[bag] with POUserFunc(org.apache.pig.builtin.Distinct)[DataBag]

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
DistinctPatcher(PhysicalPlan physicalPlan)
DistinctPatcher(PhysicalPlan plan, PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Method Summary

Modifier and Type	Method and Description
POUserFunc	getDistinct()
void	visitProject(POProject proj)

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

visit, visitAdd, visitAnd, visitBinCond, visitBroadcastSpark, visitCast, visitCollectedGroup, visitComparisonFunc, visitConstant, visitCounter, visitCross, visitDemux, visitDistinct, visitDivide, visitEqualTo, visitFilter, visitFRJoin, visitGlobalRearrange, visitGreaterThan, visitGTOrEqual, visitIsNull, visitLessThan, visitLimit, visitLoad, visitLocalRearrange, visitLTOrEqual, visitMapLookUp, visitMergeCoGroup, visitMergeJoin, visitMod, visitMultiply, visitNative, visitNegative, visitNot, visitNotEqualTo, visitOr, visitPackage, visitPartialAgg, visitPartitionRearrange, visitPOForEach, visitPoissonSample, visitPOOptimizedForEach, visitPreCombinerLocalRearrange, visitRank, visitRegexp, visitReservoirSample, visitSkewedJoin, visitSort, visitSplit, 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

DistinctPatcher

public DistinctPatcher(PhysicalPlan plan,
                       PlanWalker<PhysicalOperator,PhysicalPlan> walker)

Parameters:

plan -

walker -

DistinctPatcher

public DistinctPatcher(PhysicalPlan physicalPlan)

Parameters:

physicalPlan -

Method Detail

visitProject

public void visitProject(POProject proj)
                  throws VisitorException

Overrides:

visitProject in class PhyPlanVisitor

Throws:

VisitorException

getDistinct

public POUserFunc getDistinct()