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

Class EndOfAllInputSetter.EndOfAllInputChecker

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.EndOfAllInputSetter.EndOfAllInputChecker

Enclosing class:

EndOfAllInputSetter

public static class EndOfAllInputSetter.EndOfAllInputChecker
extends PhyPlanVisitor

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
EndOfAllInputChecker(PhysicalPlan plan)

Method Summary

Modifier and Type	Method and Description
boolean	isEndOfAllInputPresent()
void	visitCollectedGroup(POCollectedGroup mg)
void	visitLocalRearrange(POLocalRearrange lr)
void	visitMergeCoGroup(POMergeCogroup mergeCoGrp)
void	visitMergeJoin(POMergeJoin join)
void	visitPartialAgg(POPartialAgg partAgg)
void	visitPOForEach(POForEach foreach)
void	visitPoissonSample(POPoissonSample poissonSample)
void	visitReservoirSample(POReservoirSample reservoirSample)
void	visitStream(POStream stream)

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

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

EndOfAllInputChecker

public EndOfAllInputChecker(PhysicalPlan plan)

Method Detail

visitStream

public void visitStream(POStream stream)
                 throws VisitorException

Overrides:

visitStream in class PhyPlanVisitor

Throws:

VisitorException

visitMergeJoin

public void visitMergeJoin(POMergeJoin join)
                    throws VisitorException

Overrides:

visitMergeJoin in class PhyPlanVisitor

Throws:

VisitorException

visitCollectedGroup

public void visitCollectedGroup(POCollectedGroup mg)
                         throws VisitorException

Overrides:

visitCollectedGroup in class PhyPlanVisitor

Throws:

VisitorException

visitMergeCoGroup

public void visitMergeCoGroup(POMergeCogroup mergeCoGrp)
                       throws VisitorException

Overrides:

visitMergeCoGroup in class PhyPlanVisitor

Throws:

VisitorException

visitPartialAgg

public void visitPartialAgg(POPartialAgg partAgg)
                     throws VisitorException

Overrides:

visitPartialAgg in class PhyPlanVisitor

Throws:

VisitorException

visitReservoirSample

public void visitReservoirSample(POReservoirSample reservoirSample)
                          throws VisitorException

Overrides:

visitReservoirSample in class PhyPlanVisitor

Throws:

VisitorException

visitPoissonSample

public void visitPoissonSample(POPoissonSample poissonSample)
                        throws VisitorException

Overrides:

visitPoissonSample in class PhyPlanVisitor

Throws:

VisitorException

visitPOForEach

public void visitPOForEach(POForEach foreach)
                    throws VisitorException

Overrides:

visitPOForEach in class PhyPlanVisitor

Throws:

VisitorException

visitLocalRearrange

public void visitLocalRearrange(POLocalRearrange lr)
                         throws VisitorException

Overrides:

visitLocalRearrange in class PhyPlanVisitor

Throws:

VisitorException

isEndOfAllInputPresent

public boolean isEndOfAllInputPresent()

Returns:

if end of all input is present