org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans

Class ScalarPhyFinder

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.mapReduceLayer.plans.ScalarPhyFinder

public class ScalarPhyFinder
extends PhyPlanVisitor

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
ScalarPhyFinder(PhysicalPlan plan)

Method Summary

Modifier and Type	Method and Description
List<PhysicalOperator>	getScalars()
void	visitUserFunc(POUserFunc userFunc)

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, visitProject, visitRank, visitRegexp, visitReservoirSample, visitSkewedJoin, visitSort, visitSplit, visitStore, visitStream, visitSubtract, visitUnion

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

ScalarPhyFinder

public ScalarPhyFinder(PhysicalPlan plan)

Method Detail

getScalars

public List<PhysicalOperator> getScalars()

visitUserFunc

public void visitUserFunc(POUserFunc userFunc)
                   throws VisitorException

Overrides:

visitUserFunc in class PhyPlanVisitor

Throws:

VisitorException