Package org.apache.flink.optimizer.plan

Class BulkPartialSolutionPlanNode

java.lang.Object

org.apache.flink.optimizer.plan.PlanNode

org.apache.flink.optimizer.plan.BulkPartialSolutionPlanNode

All Implemented Interfaces:

DumpableNode<PlanNode>, org.apache.flink.util.Visitable<PlanNode>

public class BulkPartialSolutionPlanNode
extends PlanNode

Plan candidate node for partial solution of a bulk iteration.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.optimizer.plan.PlanNode

PlanNode.FeedbackPropertiesMeetRequirementsReport, PlanNode.SourceAndDamReport

Field Summary

Fields

Modifier and Type	Field	Description
Object	postPassHelper

Fields inherited from class org.apache.flink.optimizer.plan.PlanNode

branchPlan, cumulativeCosts, globalProps, localProps, nodeCosts, outChannels, template

Constructor Summary

Constructors

Constructor	Description
BulkPartialSolutionPlanNode(BulkPartialSolutionNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)

Method Summary

Modifier and Type	Method	Description
void	accept(org.apache.flink.util.Visitor<PlanNode> visitor)
BulkIterationPlanNode	getContainingIterationNode()
Iterable<Channel>	getInputs()
BulkPartialSolutionNode	getPartialSolutionNode()
Iterable<PlanNode>	getPredecessors()	Gets an iterator over the predecessors.
PlanNode.SourceAndDamReport	hasDamOnPathDownTo(PlanNode source)	Checks whether this node has a dam on the way down to the given source node.
void	setContainingIterationNode(BulkIterationPlanNode containingIterationNode)

Methods inherited from class org.apache.flink.optimizer.plan.PlanNode

addOutgoingChannel, checkPartialSolutionPropertiesMet, getBranchPlan, getBroadcastInputs, getCandidateAtBranchPoint, getCostWeight, getCumulativeCosts, getCumulativeCostsShare, getDriverStrategy, getDumpableInputs, getGlobalProperties, getGuaranteedAvailableMemory, getLocalProperties, getMemoryConsumerWeight, getMinResources, getNodeCosts, getNodeName, getOptimizerNode, getOriginalOptimizerNode, getOutgoingChannels, getParallelism, getPlanNode, getPreferredResources, getProgramOperator, getRelativeMemoryPerSubTask, initProperties, isOnDynamicPath, isPruneMarkerSet, mergeBranchPlanMaps, mergeBranchPlanMaps, setBroadcastInputs, setCosts, setDriverStrategy, setParallelism, setPruningMarker, setRelativeMemoryPerSubtask, toString, updatePropertiesWithUniqueSets

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

postPassHelper

public Object postPassHelper

Constructor Detail

BulkPartialSolutionPlanNode

public BulkPartialSolutionPlanNode(BulkPartialSolutionNode template,
                                   String nodeName,
                                   GlobalProperties gProps,
                                   LocalProperties lProps,
                                   Channel initialInput)

Method Detail

getPartialSolutionNode

public BulkPartialSolutionNode getPartialSolutionNode()

getContainingIterationNode

public BulkIterationPlanNode getContainingIterationNode()

setContainingIterationNode

public void setContainingIterationNode(BulkIterationPlanNode containingIterationNode)

accept

public void accept(org.apache.flink.util.Visitor<PlanNode> visitor)

getPredecessors

public Iterable<PlanNode> getPredecessors()

Description copied from interface: DumpableNode

Gets an iterator over the predecessors.

Specified by:

getPredecessors in interface DumpableNode<PlanNode>

Specified by:

getPredecessors in class PlanNode

Returns:

An iterator over the predecessors.

getInputs

public Iterable<Channel> getInputs()

Specified by:

getInputs in class PlanNode

hasDamOnPathDownTo

public PlanNode.SourceAndDamReport hasDamOnPathDownTo(PlanNode source)

Description copied from class: PlanNode

Checks whether this node has a dam on the way down to the given source node. This method returns either that (a) the source node is not found as a (transitive) child of this node, (b) the node is found, but no dam is on the path, or (c) the node is found and a dam is on the path.

Specified by:

hasDamOnPathDownTo in class PlanNode

Parameters:

source - The node on the path to which the dam is sought.

Returns:

The result whether the node is found and whether a dam is on the path.