Package org.apache.flink.optimizer.plan

Class SinkJoinerPlanNode

java.lang.Object

org.apache.flink.optimizer.plan.PlanNode

org.apache.flink.optimizer.plan.DualInputPlanNode

org.apache.flink.optimizer.plan.SinkJoinerPlanNode

All Implemented Interfaces:

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

public class SinkJoinerPlanNode
extends DualInputPlanNode

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

input1, input2, keys1, keys2, postPassHelper1, postPassHelper2, sortOrders

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

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

Constructor Summary

Constructors

Constructor	Description
SinkJoinerPlanNode(SinkJoiner template, Channel input1, Channel input2)

Method Summary

Modifier and Type	Method	Description
void	getDataSinks(List<SinkPlanNode> sinks)
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).

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

accept, getComparator1, getComparator2, getInput1, getInput2, getInputs, getKeysForInput1, getKeysForInput2, getPairComparator, getPredecessors, getSortOrders, getTwoInputNode, hasDamOnPathDownTo, setComparator1, setComparator2, setPairComparator

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, 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

SinkJoinerPlanNode

public SinkJoinerPlanNode(SinkJoiner template,
                          Channel input1,
                          Channel input2)

Method Detail

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.

getDataSinks

public void getDataSinks(List<SinkPlanNode> sinks)