org.apache.flink.optimizer.plan

Class BulkIterationPlanNode

java.lang.Object

org.apache.flink.optimizer.plan.PlanNode

org.apache.flink.optimizer.plan.SingleInputPlanNode

org.apache.flink.optimizer.plan.BulkIterationPlanNode

All Implemented Interfaces:

IterationPlanNode, DumpableNode<PlanNode>, Visitable<PlanNode>

public class BulkIterationPlanNode
extends SingleInputPlanNode
implements IterationPlanNode

Nested Class Summary

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

PlanNode.FeedbackPropertiesMeetRequirementsReport, PlanNode.SourceAndDamReport

Field Summary

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

driverKeys, driverSortOrders, input, postPassHelper

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

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

Constructor Summary

Constructors

Constructor and 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)

Method Summary

Modifier and Type	Method and Description
void	acceptForStepFunction(Visitor<PlanNode> visitor)
BulkIterationNode	getIterationNode()
int	getMemoryConsumerWeight()
BulkPartialSolutionPlanNode	getPartialSolutionPlanNode()
PlanNode	getRootOfStepFunction()
PlanNode	getRootOfTerminationCriterion()
TypeSerializerFactory<?>	getSerializerForIterationChannel()
PlanNode.SourceAndDamReport	hasDamOnPathDownTo(PlanNode source) Checks whether this node has a dam on the way down to the given source node.
void	setCosts(Costs nodeCosts) Sets the basic cost for this node to the given value, and sets the cumulative costs to those costs plus the cost shares of all inputs (regular and broadcast).
void	setSerializerForIterationChannel(TypeSerializerFactory<?> serializerForIterationChannel)

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

accept, getComparator, getInput, getInputs, getKeys, getPredecessor, getPredecessors, getSingleInputNode, getSortOrders, getTrueArray, setComparator, setDriverKeyInfo, setDriverKeyInfo

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkIterationPlanNode

public BulkIterationPlanNode(BulkIterationNode template,
                             String nodeName,
                             Channel input,
                             BulkPartialSolutionPlanNode pspn,
                             PlanNode rootOfStepFunction)

BulkIterationPlanNode

public BulkIterationPlanNode(BulkIterationNode template,
                             String nodeName,
                             Channel input,
                             BulkPartialSolutionPlanNode pspn,
                             PlanNode rootOfStepFunction,
                             PlanNode rootOfTerminationCriterion)

Method Detail

getIterationNode

public BulkIterationNode getIterationNode()

Specified by:

getIterationNode in interface IterationPlanNode

getPartialSolutionPlanNode

public BulkPartialSolutionPlanNode getPartialSolutionPlanNode()

getRootOfStepFunction

public PlanNode getRootOfStepFunction()

getRootOfTerminationCriterion

public PlanNode getRootOfTerminationCriterion()

getSerializerForIterationChannel

public TypeSerializerFactory<?> getSerializerForIterationChannel()

setSerializerForIterationChannel

public void setSerializerForIterationChannel(TypeSerializerFactory<?> serializerForIterationChannel)

setCosts

public void setCosts(Costs nodeCosts)

Description copied from class: PlanNode

Sets the basic cost for this node to the given value, and sets the cumulative costs to those costs plus the cost shares of all inputs (regular and broadcast).

Overrides:

setCosts in class PlanNode

Parameters:

nodeCosts - The already knows costs for this node (this cost a produces by a concrete OptimizerNode subclass.

getMemoryConsumerWeight

public int getMemoryConsumerWeight()

Overrides:

getMemoryConsumerWeight 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.

Overrides:

hasDamOnPathDownTo in class SingleInputPlanNode

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.

acceptForStepFunction

public void acceptForStepFunction(Visitor<PlanNode> visitor)

Specified by:

acceptForStepFunction in interface IterationPlanNode