public class UDFEndOfAllInputNeededVisitor extends PhyPlanVisitor
mCurrentWalker, mPlan
Constructor and Description |
---|
UDFEndOfAllInputNeededVisitor(PhysicalPlan plan) |
Modifier and Type | Method and Description |
---|---|
boolean |
needEndOfAllInputProcessing() |
void |
visitUserFunc(POUserFunc userFunc) |
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
getPlan, popWalker, pushWalker, visit
public UDFEndOfAllInputNeededVisitor(PhysicalPlan plan)
public void visitUserFunc(POUserFunc userFunc) throws VisitorException
visitUserFunc
in class PhyPlanVisitor
VisitorException
public boolean needEndOfAllInputProcessing()
Copyright © 2007-2017 The Apache Software Foundation