Package org.apache.flink.optimizer.plan

Class SinkPlanNode

java.lang.Object

org.apache.flink.optimizer.plan.PlanNode

org.apache.flink.optimizer.plan.SingleInputPlanNode

org.apache.flink.optimizer.plan.SinkPlanNode

All Implemented Interfaces:

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

public class SinkPlanNode
extends SingleInputPlanNode

Plan candidate node for data flow sinks.

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	Description
SinkPlanNode(DataSinkNode template, String nodeName, Channel input)	Constructs a new sink candidate node that uses NONE as its local strategy.

Method Summary

Modifier and Type	Method	Description
DataSinkNode	getSinkNode()

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

accept, getComparator, getInput, getInputs, getKeys, getPredecessor, getPredecessors, getSingleInputNode, getSortOrders, getTrueArray, hasDamOnPathDownTo, 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, 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

Constructor Detail

SinkPlanNode

public SinkPlanNode(DataSinkNode template,
                    String nodeName,
                    Channel input)

Constructs a new sink candidate node that uses NONE as its local strategy. Note that local sorting and range partitioning are handled by the incoming channel already.

Parameters:

template - The template optimizer node that this candidate is created for.

Method Detail

getSinkNode

public DataSinkNode getSinkNode()