Package org.apache.flink.optimizer.dag
Class OptimizerNode.UnclosedBranchDescriptor
- java.lang.Object
-
- org.apache.flink.optimizer.dag.OptimizerNode.UnclosedBranchDescriptor
-
- Enclosing class:
- OptimizerNode
public static final class OptimizerNode.UnclosedBranchDescriptor extends Object
Description of an unclosed branch. An unclosed branch is when the data flow branched (one operator's result is consumed by multiple targets), but these different branches (targets) have not been joined together.
-
-
Field Summary
Fields Modifier and Type Field Description protected OptimizerNodebranchingNodeprotected longjoinedPathsVector
-
Constructor Summary
Constructors Modifier Constructor Description protectedUnclosedBranchDescriptor(OptimizerNode branchingNode, long joinedPathsVector)Creates a new branching descriptor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description OptimizerNodegetBranchingNode()longgetJoinedPathsVector()StringtoString()
-
-
-
Field Detail
-
branchingNode
protected OptimizerNode branchingNode
-
joinedPathsVector
protected long joinedPathsVector
-
-
Constructor Detail
-
UnclosedBranchDescriptor
protected UnclosedBranchDescriptor(OptimizerNode branchingNode, long joinedPathsVector)
Creates a new branching descriptor.- Parameters:
branchingNode- The node where the branch occurred (the node with multiple outputs).joinedPathsVector- A bit vector describing which branches are tracked by this descriptor. The bit vector is one, where the branch is tracked, zero otherwise.
-
-
Method Detail
-
getBranchingNode
public OptimizerNode getBranchingNode()
-
getJoinedPathsVector
public long getJoinedPathsVector()
-
-