public static class TezOperDependencyParallelismEstimator.TezParallelismFactorVisitor extends PhyPlanVisitor
mCurrentWalker, mPlan
Constructor and Description |
---|
TezParallelismFactorVisitor(TezOperator tezOp,
TezOperator successor) |
Modifier and Type | Method and Description |
---|---|
double |
getFactor() |
void |
visitFilter(POFilter fl) |
void |
visitFRJoin(POFRJoin join) |
void |
visitLimit(POLimit lim) |
void |
visitMergeJoin(POMergeJoin join) |
void |
visitPackage(POPackage pkg) |
void |
visitPOForEach(POForEach nfe) |
void |
visitSplit(POSplit sp) |
visit, visitAdd, visitAnd, visitBinCond, visitBroadcastSpark, visitCast, visitCollectedGroup, visitComparisonFunc, visitConstant, visitCounter, visitCross, visitDemux, visitDistinct, visitDivide, visitEqualTo, visitGlobalRearrange, visitGreaterThan, visitGTOrEqual, visitIsNull, visitLessThan, visitLoad, visitLocalRearrange, visitLTOrEqual, visitMapLookUp, visitMergeCoGroup, visitMod, visitMultiply, visitNative, visitNegative, visitNot, visitNotEqualTo, visitOr, visitPartialAgg, visitPartitionRearrange, visitPoissonSample, visitPOOptimizedForEach, visitPreCombinerLocalRearrange, visitProject, visitRank, visitRegexp, visitReservoirSample, visitSkewedJoin, visitSort, visitStore, visitStream, visitSubtract, visitUnion, visitUserFunc
getPlan, popWalker, pushWalker, visit
public TezParallelismFactorVisitor(TezOperator tezOp, TezOperator successor)
public void visitFilter(POFilter fl) throws VisitorException
visitFilter
in class PhyPlanVisitor
VisitorException
public void visitPOForEach(POForEach nfe) throws VisitorException
visitPOForEach
in class PhyPlanVisitor
VisitorException
public void visitLimit(POLimit lim) throws VisitorException
visitLimit
in class PhyPlanVisitor
VisitorException
public void visitFRJoin(POFRJoin join) throws VisitorException
visitFRJoin
in class PhyPlanVisitor
VisitorException
public void visitMergeJoin(POMergeJoin join) throws VisitorException
visitMergeJoin
in class PhyPlanVisitor
VisitorException
public void visitPackage(POPackage pkg) throws VisitorException
visitPackage
in class PhyPlanVisitor
VisitorException
public void visitSplit(POSplit sp) throws VisitorException
visitSplit
in class PhyPlanVisitor
VisitorException
public double getFactor()
Copyright © 2007-2017 The Apache Software Foundation