Uses of Class
org.apache.flink.optimizer.dag.OptimizerNode

Packages that use OptimizerNode

Package	Description
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.dataproperties
org.apache.flink.optimizer.plan
org.apache.flink.optimizer.plandump
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 OptimizerNode in org.apache.flink.optimizer.dag

Subclasses of OptimizerNode in org.apache.flink.optimizer.dag

Modifier and Type	Class	Description
class	AbstractPartialSolutionNode	The optimizer's internal representation of the partial solution that is input to a bulk iteration.
class	BinaryUnionNode	The Optimizer representation of a binary Union.
class	BulkIterationNode	A node in the optimizer's program representation for a bulk iteration.
class	BulkPartialSolutionNode	The optimizer's internal representation of the partial solution that is input to a bulk iteration.
class	CoGroupNode	The Optimizer representation of a CoGroup operator.
class	CoGroupRawNode	The Optimizer representation of a CoGroupRaw operator.
class	CrossNode	The Optimizer representation of a Cross (Cartesian product) operator.
class	DataSinkNode	The Optimizer representation of a data sink.
class	DataSourceNode	The optimizer's internal representation of a data source.
class	FilterNode	The optimizer's internal representation of a Filter operator node.
class	FlatMapNode	The optimizer's internal representation of a FlatMap operator node.
class	GroupCombineNode	The optimizer representation of a GroupCombineNode operation.
class	GroupReduceNode	The optimizer representation of a GroupReduce operation.
class	JoinNode	The Optimizer representation of a join operator.
class	MapNode	The optimizer's internal representation of a Map operator node.
class	MapPartitionNode	The optimizer's internal representation of a MapPartition operator node.
class	NoOpNode	The optimizer's internal representation of a No Operation node.
class	OuterJoinNode
class	PartitionNode	The optimizer's internal representation of a Partition operator node.
class	ReduceNode	The Optimizer representation of a Reduce operator.
class	SingleInputNode	A node in the optimizer's program representation for an operation with a single input.
class	SinkJoiner	This class represents a utility node that is not part of the actual plan.
class	SolutionSetNode	The optimizer's internal representation of the solution set of a workset iteration.
class	SortPartitionNode	The optimizer's internal representation of a SortPartition operator node.
class	TwoInputNode	A node in the optimizer plan that represents an operator with a two different inputs, such as Join, Cross, CoGroup, or Union.
class	UnaryOperatorNode
class	WorksetIterationNode	A node in the optimizer's program representation for a workset iteration.
static class	WorksetIterationNode.SingleRootJoiner
class	WorksetNode	The optimizer's internal representation of the partial solution that is input to a bulk iteration.

Fields in org.apache.flink.optimizer.dag declared as OptimizerNode

Modifier and Type	Field	Description
protected OptimizerNode	OptimizerNode.UnclosedBranchDescriptor.branchingNode

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

Modifier and Type	Field	Description
protected Set<OptimizerNode>	OptimizerNode.closedBranchingNodes
protected List<OptimizerNode>	OptimizerNode.hereJoinedBranches

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

Modifier and Type	Method	Description
OptimizerNode	OptimizerNode.UnclosedBranchDescriptor.getBranchingNode()
OptimizerNode	TwoInputNode.getFirstPredecessorNode()
OptimizerNode	WorksetIterationNode.getInitialSolutionSetPredecessorNode()
OptimizerNode	WorksetIterationNode.getInitialWorksetPredecessorNode()
OptimizerNode	BulkIterationNode.getNextPartialSolution()	Gets the nextPartialSolution from this BulkIterationNode.
OptimizerNode	WorksetIterationNode.getNextWorkset()
OptimizerNode	OptimizerNode.getOptimizerNode()
OptimizerNode	DataSinkNode.getPredecessorNode()	Gets the predecessor of this node.
OptimizerNode	SingleInputNode.getPredecessorNode()	Gets the predecessor of this node.
OptimizerNode	TwoInputNode.getSecondPredecessorNode()
OptimizerNode	BulkIterationNode.getSingleRootOfStepFunction()
OptimizerNode	WorksetIterationNode.getSolutionSetDelta()
OptimizerNode	DagConnection.getSource()	Gets the source of the connection.
OptimizerNode	DagConnection.getTarget()	Gets the target of the connection.

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

Modifier and Type	Method	Description
Set<OptimizerNode>	OptimizerNode.getClosedBranchingNodes()
Iterable<DumpableConnection<OptimizerNode>>	OptimizerNode.getDumpableInputs()
Iterable<OptimizerNode>	OptimizerNode.getPredecessors()

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

Modifier and Type	Method	Description
protected void	OptimizerNode.addClosedBranch(OptimizerNode alreadyClosed)
protected void	AbstractPartialSolutionNode.copyEstimates(OptimizerNode node)
void	BulkIterationNode.setNextPartialSolution(OptimizerNode nextPartialSolution, OptimizerNode terminationCriterion)	Sets the nextPartialSolution for this BulkIterationNode.
void	WorksetIterationNode.setNextPartialSolution(OptimizerNode solutionSetDelta, OptimizerNode nextWorkset, org.apache.flink.api.common.ExecutionMode executionMode)

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

Modifier and Type	Method	Description
void	AbstractPartialSolutionNode.accept(org.apache.flink.util.Visitor<OptimizerNode> visitor)
void	DataSinkNode.accept(org.apache.flink.util.Visitor<OptimizerNode> visitor)
void	DataSourceNode.accept(org.apache.flink.util.Visitor<OptimizerNode> visitor)
abstract void	OptimizerNode.accept(org.apache.flink.util.Visitor<OptimizerNode> visitor)	This method implements the visit of a depth-first graph traversing visitor.
void	SingleInputNode.accept(org.apache.flink.util.Visitor<OptimizerNode> visitor)
void	TwoInputNode.accept(org.apache.flink.util.Visitor<OptimizerNode> visitor)
void	BulkIterationNode.acceptForStepFunction(org.apache.flink.util.Visitor<OptimizerNode> visitor)
void	IterationNode.acceptForStepFunction(org.apache.flink.util.Visitor<OptimizerNode> visitor)
void	WorksetIterationNode.acceptForStepFunction(org.apache.flink.util.Visitor<OptimizerNode> visitor)
protected void	OptimizerNode.addClosedBranches(Set<OptimizerNode> alreadyClosed)
void	OptimizerNode.setBroadcastInputs(Map<org.apache.flink.api.common.operators.Operator<?>,OptimizerNode> operatorToNode, org.apache.flink.api.common.ExecutionMode defaultExchangeMode)	This function connects the operators that produce the broadcast inputs to this operator.
void	AbstractPartialSolutionNode.setInput(Map<org.apache.flink.api.common.operators.Operator<?>,OptimizerNode> contractToNode, org.apache.flink.api.common.ExecutionMode dataExchangeMode)
void	DataSinkNode.setInput(Map<org.apache.flink.api.common.operators.Operator<?>,OptimizerNode> contractToNode, org.apache.flink.api.common.ExecutionMode defaultExchangeMode)
void	DataSourceNode.setInput(Map<org.apache.flink.api.common.operators.Operator<?>,OptimizerNode> contractToNode, org.apache.flink.api.common.ExecutionMode defaultDataExchangeMode)
abstract void	OptimizerNode.setInput(Map<org.apache.flink.api.common.operators.Operator<?>,OptimizerNode> operatorToNode, org.apache.flink.api.common.ExecutionMode defaultExchangeMode)	This function connects the predecessors to this operator.
void	SingleInputNode.setInput(Map<org.apache.flink.api.common.operators.Operator<?>,OptimizerNode> contractToNode, org.apache.flink.api.common.ExecutionMode defaultExchangeMode)
void	TwoInputNode.setInput(Map<org.apache.flink.api.common.operators.Operator<?>,OptimizerNode> contractToNode, org.apache.flink.api.common.ExecutionMode defaultExecutionMode)

Constructors in org.apache.flink.optimizer.dag with parameters of type OptimizerNode

Constructor	Description
DagConnection(OptimizerNode source, org.apache.flink.api.common.ExecutionMode exchangeMode)	Constructor to create a result from an operator that is not consumed by another operator.
DagConnection(OptimizerNode source, OptimizerNode target, org.apache.flink.api.common.ExecutionMode exchangeMode)	Creates a new Connection between two nodes.
DagConnection(OptimizerNode source, OptimizerNode target, org.apache.flink.runtime.operators.shipping.ShipStrategyType shipStrategy, org.apache.flink.api.common.ExecutionMode exchangeMode)	Creates a new Connection between two nodes.
OptimizerNode(OptimizerNode toCopy)
SinkJoiner(OptimizerNode input1, OptimizerNode input2)
UnclosedBranchDescriptor(OptimizerNode branchingNode, long joinedPathsVector)	Creates a new branching descriptor.

Uses of OptimizerNode in org.apache.flink.optimizer.dataproperties

Methods in org.apache.flink.optimizer.dataproperties with parameters of type OptimizerNode

Modifier and Type	Method	Description
InterestingProperties	InterestingProperties.filterByCodeAnnotations(OptimizerNode node, int input)

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

Fields in org.apache.flink.optimizer.plan declared as OptimizerNode

Modifier and Type	Field	Description
protected OptimizerNode	PlanNode.template

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

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

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

Modifier and Type	Method	Description
OptimizerNode	PlanNode.getOptimizerNode()
OptimizerNode	PlanNode.getOriginalOptimizerNode()	Gets the node from the optimizer DAG for which this plan candidate node was created.

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

Modifier and Type	Method	Description
Map<OptimizerNode,PlanNode>	PlanNode.getBranchPlan()

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

Modifier and Type	Method	Description
PlanNode	PlanNode.getCandidateAtBranchPoint(OptimizerNode branchPoint)

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

Modifier and Type	Method	Description
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 OptimizerNode

Constructor	Description
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, org.apache.flink.runtime.operators.DriverStrategy diverStrategy)
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, org.apache.flink.runtime.operators.DriverStrategy diverStrategy, org.apache.flink.api.common.operators.util.FieldList driverKeyFields1, org.apache.flink.api.common.operators.util.FieldList driverKeyFields2)
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, org.apache.flink.runtime.operators.DriverStrategy diverStrategy, org.apache.flink.api.common.operators.util.FieldList driverKeyFields1, org.apache.flink.api.common.operators.util.FieldList driverKeyFields2, boolean[] driverSortOrders)
PlanNode(OptimizerNode template, String nodeName, org.apache.flink.runtime.operators.DriverStrategy strategy)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, org.apache.flink.runtime.operators.DriverStrategy driverStrategy)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, org.apache.flink.runtime.operators.DriverStrategy driverStrategy, org.apache.flink.api.common.operators.util.FieldList driverKeyFields)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, org.apache.flink.runtime.operators.DriverStrategy driverStrategy, org.apache.flink.api.common.operators.util.FieldList driverKeyFields, boolean[] driverSortOrders)

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

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

Modifier and Type	Method	Description
OptimizerNode	DumpableNode.getOptimizerNode()

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

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

Modifier and Type	Method	Description
void	BranchesVisitor.postVisit(OptimizerNode node)
void	IdAndEstimatesVisitor.postVisit(OptimizerNode visitable)
void	InterestingPropertyVisitor.postVisit(OptimizerNode visitable)
void	StaticDynamicPathIdentifier.postVisit(OptimizerNode visitable)
void	UnionParallelismAndForwardEnforcer.postVisit(OptimizerNode node)
boolean	BranchesVisitor.preVisit(OptimizerNode node)
boolean	IdAndEstimatesVisitor.preVisit(OptimizerNode visitable)
boolean	InterestingPropertyVisitor.preVisit(OptimizerNode node)
boolean	StaticDynamicPathIdentifier.preVisit(OptimizerNode visitable)
boolean	UnionParallelismAndForwardEnforcer.preVisit(OptimizerNode node)