Uses of Class
org.apache.flink.optimizer.plan.PlanNode

Packages that use PlanNode

Package	Description
org.apache.flink.optimizer.costs
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.plan
org.apache.flink.optimizer.plandump
org.apache.flink.optimizer.plantranslate
org.apache.flink.optimizer.postpass
org.apache.flink.optimizer.traversals	This package contains the various traversals over the program plan and the optimizer DAG (directed acyclic graph) that are made in the course of the optimization.

Uses of PlanNode in org.apache.flink.optimizer.costs

Methods in org.apache.flink.optimizer.costs with parameters of type PlanNode

Modifier and Type	Method	Description
void	CostEstimator.costOperator(PlanNode n)	This method computes the cost of an operator.

Uses of PlanNode in org.apache.flink.optimizer.dag

Fields in org.apache.flink.optimizer.dag with type parameters of type PlanNode

Modifier and Type	Field	Description
protected List<PlanNode>	OptimizerNode.cachedPlans

Methods in org.apache.flink.optimizer.dag that return PlanNode

Modifier and Type	Method	Description
PlanNode	OptimizerNode.getPlanNode()

Methods in org.apache.flink.optimizer.dag that return types with arguments of type PlanNode

Modifier and Type	Method	Description
List<PlanNode>	AbstractPartialSolutionNode.getAlternativePlans(CostEstimator estimator)
List<PlanNode>	BinaryUnionNode.getAlternativePlans(CostEstimator estimator)
List<PlanNode>	DataSinkNode.getAlternativePlans(CostEstimator estimator)
List<PlanNode>	DataSourceNode.getAlternativePlans(CostEstimator estimator)
abstract List<PlanNode>	OptimizerNode.getAlternativePlans(CostEstimator estimator)	Computes the plan alternatives for this node, an implicitly for all nodes that are children of this node.
List<PlanNode>	SingleInputNode.getAlternativePlans(CostEstimator estimator)
List<PlanNode>	TwoInputNode.getAlternativePlans(CostEstimator estimator)

Methods in org.apache.flink.optimizer.dag with parameters of type PlanNode

Modifier and Type	Method	Description
protected boolean	OptimizerNode.areBranchCompatible(PlanNode plan1, PlanNode plan2)	Checks whether to candidate plans for the sub-plan of this node are comparable.

Method parameters in org.apache.flink.optimizer.dag with type arguments of type PlanNode

Modifier and Type	Method	Description
protected void	OptimizerNode.prunePlanAlternatives(List<PlanNode> plans)
protected void	OptimizerNode.prunePlanAlternativesWithCommonBranching(List<PlanNode> plans)

Uses of PlanNode in org.apache.flink.optimizer.plan

Subclasses of PlanNode in org.apache.flink.optimizer.plan

Modifier and Type	Class	Description
class	BinaryUnionPlanNode	A special subclass for the union to make it identifiable.
class	BulkIterationPlanNode
class	BulkPartialSolutionPlanNode	Plan candidate node for partial solution of a bulk iteration.
class	DualInputPlanNode
class	NAryUnionPlanNode	A union operation over multiple inputs (2 or more).
class	SingleInputPlanNode
class	SinkJoinerPlanNode
class	SinkPlanNode	Plan candidate node for data flow sinks.
class	SolutionSetPlanNode	Plan candidate node for partial solution of a bulk iteration.
class	SourcePlanNode	Plan candidate node for data flow sources that have no input and no special strategies.
class	WorksetIterationPlanNode	A node in the execution, representing a workset iteration (delta iteration).
class	WorksetPlanNode	Plan candidate node for partial solution of a bulk iteration.

Fields in org.apache.flink.optimizer.plan with type parameters of type PlanNode

Modifier and Type	Field	Description
protected Map<OptimizerNode,PlanNode>	PlanNode.branchPlan

Methods in org.apache.flink.optimizer.plan that return PlanNode

Modifier and Type	Method	Description
PlanNode	PlanNode.getCandidateAtBranchPoint(OptimizerNode branchPoint)
PlanNode	WorksetIterationPlanNode.getNextWorkSetPlanNode()
PlanNode	PlanNode.getPlanNode()
PlanNode	SingleInputPlanNode.getPredecessor()	Gets the predecessor of this node, i.e.
PlanNode	BulkIterationPlanNode.getRootOfStepFunction()
PlanNode	BulkIterationPlanNode.getRootOfTerminationCriterion()
PlanNode	WorksetIterationPlanNode.getSolutionSetDeltaPlanNode()
PlanNode	Channel.getSource()	Gets the source of this Channel.
PlanNode	Channel.getTarget()	Gets the target of this Channel.

Methods in org.apache.flink.optimizer.plan that return types with arguments of type PlanNode

Modifier and Type	Method	Description
Collection<PlanNode>	OptimizedPlan.getAllNodes()	Gets all the nodes from this OptimizedPlan.
Map<OptimizerNode,PlanNode>	PlanNode.getBranchPlan()
Iterable<DumpableConnection<PlanNode>>	PlanNode.getDumpableInputs()
Iterable<PlanNode>	BulkPartialSolutionPlanNode.getPredecessors()
Iterable<PlanNode>	DualInputPlanNode.getPredecessors()
Iterable<PlanNode>	NAryUnionPlanNode.getPredecessors()
abstract Iterable<PlanNode>	PlanNode.getPredecessors()
Iterable<PlanNode>	SingleInputPlanNode.getPredecessors()
Iterable<PlanNode>	SolutionSetPlanNode.getPredecessors()
Iterable<PlanNode>	SourcePlanNode.getPredecessors()
Iterable<PlanNode>	WorksetPlanNode.getPredecessors()

Methods in org.apache.flink.optimizer.plan with parameters of type PlanNode

Modifier and Type	Method	Description
PlanNode.FeedbackPropertiesMeetRequirementsReport	PlanNode.checkPartialSolutionPropertiesMet(PlanNode partialSolution, GlobalProperties feedbackGlobal, LocalProperties feedbackLocal)
PlanNode.SourceAndDamReport	BulkIterationPlanNode.hasDamOnPathDownTo(PlanNode source)
PlanNode.SourceAndDamReport	BulkPartialSolutionPlanNode.hasDamOnPathDownTo(PlanNode source)
PlanNode.SourceAndDamReport	DualInputPlanNode.hasDamOnPathDownTo(PlanNode source)
PlanNode.SourceAndDamReport	NAryUnionPlanNode.hasDamOnPathDownTo(PlanNode source)
abstract PlanNode.SourceAndDamReport	PlanNode.hasDamOnPathDownTo(PlanNode source)	Checks whether this node has a dam on the way down to the given source node.
PlanNode.SourceAndDamReport	SingleInputPlanNode.hasDamOnPathDownTo(PlanNode source)
PlanNode.SourceAndDamReport	SolutionSetPlanNode.hasDamOnPathDownTo(PlanNode source)
PlanNode.SourceAndDamReport	SourcePlanNode.hasDamOnPathDownTo(PlanNode source)
PlanNode.SourceAndDamReport	WorksetIterationPlanNode.hasDamOnPathDownTo(PlanNode source)
PlanNode.SourceAndDamReport	WorksetPlanNode.hasDamOnPathDownTo(PlanNode source)
protected void	PlanNode.mergeBranchPlanMaps(PlanNode pred1, PlanNode pred2)
void	Channel.setSource(PlanNode source)
void	Channel.setTarget(PlanNode target)	Sets the target of this Channel.
void	Channel.swapUnionNodes(PlanNode newUnionNode)	Utility method used while swapping binary union nodes for n-ary union nodes.

Method parameters in org.apache.flink.optimizer.plan with type arguments of type PlanNode

Modifier and Type	Method	Description
void	BulkPartialSolutionPlanNode.accept(org.apache.flink.util.Visitor<PlanNode> visitor)
void	DualInputPlanNode.accept(org.apache.flink.util.Visitor<PlanNode> visitor)
void	NAryUnionPlanNode.accept(org.apache.flink.util.Visitor<PlanNode> visitor)
void	OptimizedPlan.accept(org.apache.flink.util.Visitor<PlanNode> visitor)	Applies the given visitor top down to all nodes, starting at the sinks.
void	SingleInputPlanNode.accept(org.apache.flink.util.Visitor<PlanNode> visitor)
void	SolutionSetPlanNode.accept(org.apache.flink.util.Visitor<PlanNode> visitor)
void	SourcePlanNode.accept(org.apache.flink.util.Visitor<PlanNode> visitor)
void	WorksetPlanNode.accept(org.apache.flink.util.Visitor<PlanNode> visitor)
void	BulkIterationPlanNode.acceptForStepFunction(org.apache.flink.util.Visitor<PlanNode> visitor)
void	IterationPlanNode.acceptForStepFunction(org.apache.flink.util.Visitor<PlanNode> visitor)
void	WorksetIterationPlanNode.acceptForStepFunction(org.apache.flink.util.Visitor<PlanNode> visitor)
protected void	PlanNode.mergeBranchPlanMaps(Map<OptimizerNode,PlanNode> branchPlan1, Map<OptimizerNode,PlanNode> branchPlan2)
protected void	WorksetIterationPlanNode.mergeBranchPlanMaps(Map<OptimizerNode,PlanNode> branchPlan1, Map<OptimizerNode,PlanNode> branchPlan2)	Merging can only take place after the solutionSetDelta and nextWorkset PlanNode has been set, because they can contain also some of the branching nodes.

Constructors in org.apache.flink.optimizer.plan with parameters of type PlanNode

Constructor	Description
BulkIterationPlanNode(BulkIterationNode template, String nodeName, Channel input, BulkPartialSolutionPlanNode pspn, PlanNode rootOfStepFunction)
BulkIterationPlanNode(BulkIterationNode template, String nodeName, Channel input, BulkPartialSolutionPlanNode pspn, PlanNode rootOfStepFunction, PlanNode rootOfTerminationCriterion)
Channel(PlanNode sourceNode)
Channel(PlanNode sourceNode, TempMode tempMode)
NamedChannel(String name, PlanNode sourceNode)	Initializes NamedChannel.
NamedChannel(String name, PlanNode sourceNode, TempMode tempMode)
WorksetIterationPlanNode(WorksetIterationNode template, String nodeName, Channel initialSolutionSet, Channel initialWorkset, SolutionSetPlanNode solutionSetPlanNode, WorksetPlanNode worksetPlanNode, PlanNode nextWorkSetPlanNode, PlanNode solutionSetDeltaPlanNode)

Uses of PlanNode in org.apache.flink.optimizer.plandump

Methods in org.apache.flink.optimizer.plandump that return PlanNode

Modifier and Type	Method	Description
PlanNode	DumpableNode.getPlanNode()

Uses of PlanNode in org.apache.flink.optimizer.plantranslate

Methods in org.apache.flink.optimizer.plantranslate with parameters of type PlanNode

Modifier and Type	Method	Description
static String	JsonMapper.getOptimizerPropertiesJson(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonFactory jsonFactory, PlanNode node)
void	JobGraphGenerator.postVisit(PlanNode node)	This method implements the post-visit during the depth-first traversal.
boolean	JobGraphGenerator.preVisit(PlanNode node)	This methods implements the pre-visiting during a depth-first traversal.

Uses of PlanNode in org.apache.flink.optimizer.postpass

Methods in org.apache.flink.optimizer.postpass with parameters of type PlanNode

Modifier and Type	Method	Description
protected void	JavaApiPostPass.traverse(PlanNode node)

Uses of PlanNode in org.apache.flink.optimizer.traversals

Methods in org.apache.flink.optimizer.traversals with parameters of type PlanNode

Modifier and Type	Method	Description
void	BinaryUnionReplacer.postVisit(PlanNode visitable)
void	PlanFinalizer.postVisit(PlanNode visitable)
void	RangePartitionRewriter.postVisit(PlanNode node)
boolean	BinaryUnionReplacer.preVisit(PlanNode visitable)
boolean	PlanFinalizer.preVisit(PlanNode visitable)
boolean	RangePartitionRewriter.preVisit(PlanNode visitable)