Uses of Class
org.apache.flink.optimizer.plan.Channel

Packages that use Channel

Package	Description
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.dataproperties
org.apache.flink.optimizer.operators
org.apache.flink.optimizer.plan
org.apache.flink.optimizer.traversals	This package contains the various traversals over the program plan and the optimizer DAG (directed acyclic graph) that are made in the course of the optimization.
org.apache.flink.optimizer.util

Uses of Channel in org.apache.flink.optimizer.dag

Methods in org.apache.flink.optimizer.dag with parameters of type Channel

Modifier and Type	Method and Description
protected void	TwoInputNode.addLocalCandidates(Channel template1, Channel template2, List<Set<? extends NamedChannel>> broadcastPlanChannels, RequestedGlobalProperties rgps1, RequestedGlobalProperties rgps2, List<PlanNode> target, OperatorDescriptorDual.LocalPropertiesPair[] validLocalCombinations, CostEstimator estimator)
protected void	SingleInputNode.addLocalCandidates(Channel template, List<Set<? extends NamedChannel>> broadcastPlanChannels, RequestedGlobalProperties rgps, List<PlanNode> target, CostEstimator estimator)
SingleInputPlanNode	PartitionNode.PartitionDescriptor.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	SortPartitionNode.SortPartitionDescriptor.instantiate(Channel in, SingleInputNode node)
protected void	TwoInputNode.instantiate(OperatorDescriptorDual operator, Channel in1, Channel in2, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq1, RequestedGlobalProperties globPropsReq2, RequestedLocalProperties locPropsReq1, RequestedLocalProperties locPropsReq2)
protected void	WorksetIterationNode.instantiate(OperatorDescriptorDual operator, Channel solutionSetIn, Channel worksetIn, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReqSolutionSet, RequestedGlobalProperties globPropsReqWorkset, RequestedLocalProperties locPropsReqSolutionSet, RequestedLocalProperties locPropsReqWorkset)
protected void	BulkIterationNode.instantiateCandidate(OperatorDescriptorSingle dps, Channel in, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq, RequestedLocalProperties locPropsReq)
protected void	SingleInputNode.instantiateCandidate(OperatorDescriptorSingle dps, Channel in, List<Set<? extends NamedChannel>> broadcastPlanChannels, List<PlanNode> target, CostEstimator estimator, RequestedGlobalProperties globPropsReq, RequestedLocalProperties locPropsReq)
protected void	TwoInputNode.placePipelineBreakersIfNecessary(DriverStrategy strategy, Channel in1, Channel in2)
void	BulkPartialSolutionNode.setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
void	WorksetNode.setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
void	SolutionSetNode.setCandidateProperties(GlobalProperties gProps, LocalProperties lProps, Channel initialInput)

Uses of Channel in org.apache.flink.optimizer.dataproperties

Methods in org.apache.flink.optimizer.dataproperties with parameters of type Channel

Modifier and Type	Method and Description
void	RequestedLocalProperties.parameterizeChannel(Channel channel) Parametrizes the local strategy fields of a channel such that the channel produces the desired local properties.
void	GlobalProperties.parameterizeChannel(Channel channel, boolean globalDopChange, ExecutionMode exchangeMode, boolean breakPipeline)
void	RequestedGlobalProperties.parameterizeChannel(Channel channel, boolean globalDopChange, ExecutionMode exchangeMode, boolean breakPipeline) Parametrizes the ship strategy fields of a channel such that the channel produces the desired global properties.

Uses of Channel in org.apache.flink.optimizer.operators

Methods in org.apache.flink.optimizer.operators with parameters of type Channel

Modifier and Type	Method and Description
DualInputPlanNode	HashFullOuterJoinBuildFirstDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CoGroupRawDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	AbstractSortMergeJoinDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	BinaryUnionOpDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CoGroupWithSolutionSetFirstDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashFullOuterJoinBuildSecondDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
abstract DualInputPlanNode	OperatorDescriptorDual.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashRightOuterJoinBuildSecondDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashLeftOuterJoinBuildFirstDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashLeftOuterJoinBuildSecondDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	UtilSinkJoinOpDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashJoinBuildSecondProperties.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CoGroupDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashRightOuterJoinBuildFirstDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashJoinBuildFirstProperties.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CartesianProductDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
SingleInputPlanNode	SolutionSetDeltaOperator.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	NoOpDescriptor.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	FilterDescriptor.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	MapPartitionDescriptor.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	ReduceProperties.instantiate(Channel in, SingleInputNode node)
abstract SingleInputPlanNode	OperatorDescriptorSingle.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	AllGroupCombineProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	GroupCombineProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	AllGroupReduceProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	AllGroupWithPartialPreGroupProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	GroupReduceWithCombineProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	PartialGroupProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	FlatMapDescriptor.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	AllReduceProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	GroupReduceProperties.instantiate(Channel in, SingleInputNode node)
SingleInputPlanNode	MapDescriptor.instantiate(Channel in, SingleInputNode node)

Uses of Channel in org.apache.flink.optimizer.plan

Subclasses of Channel in org.apache.flink.optimizer.plan

Modifier and Type	Class and Description
class	NamedChannel

Fields in org.apache.flink.optimizer.plan declared as Channel

Modifier and Type	Field and Description
protected Channel	SingleInputPlanNode.input
protected Channel	DualInputPlanNode.input1
protected Channel	DualInputPlanNode.input2

Fields in org.apache.flink.optimizer.plan with type parameters of type Channel

Modifier and Type	Field and Description
protected List<Channel>	PlanNode.outChannels

Methods in org.apache.flink.optimizer.plan that return Channel

Modifier and Type	Method and Description
Channel	Channel.clone()
Channel	WorksetIterationPlanNode.getInitialSolutionSetInput()
Channel	WorksetIterationPlanNode.getInitialWorksetInput()
Channel	SingleInputPlanNode.getInput() Gets the input channel to this node.
Channel	DualInputPlanNode.getInput1() Gets the first input channel to this node.
Channel	DualInputPlanNode.getInput2() Gets the second input channel to this node.

Methods in org.apache.flink.optimizer.plan that return types with arguments of type Channel

Modifier and Type	Method and Description
Iterable<Channel>	SolutionSetPlanNode.getInputs()
Iterable<Channel>	DualInputPlanNode.getInputs()
Iterable<Channel>	SourcePlanNode.getInputs()
Iterable<Channel>	BulkPartialSolutionPlanNode.getInputs()
Iterable<Channel>	NAryUnionPlanNode.getInputs()
Iterable<Channel>	SingleInputPlanNode.getInputs()
Iterable<Channel>	WorksetPlanNode.getInputs()
abstract Iterable<Channel>	PlanNode.getInputs()
List<Channel>	NAryUnionPlanNode.getListOfInputs()
List<Channel>	PlanNode.getOutgoingChannels() Gets a list of all outgoing channels leading to successors.

Methods in org.apache.flink.optimizer.plan with parameters of type Channel

Modifier and Type	Method and Description
void	PlanNode.addOutgoingChannel(Channel channel) Adds a channel to a successor node to this node.

Constructors in org.apache.flink.optimizer.plan with parameters of type Channel

Constructor and Description
BinaryUnionPlanNode(BinaryUnionNode template, Channel in1, Channel in2)
BulkIterationPlanNode(BulkIterationNode template, String nodeName, Channel input, BulkPartialSolutionPlanNode pspn, PlanNode rootOfStepFunction)
BulkIterationPlanNode(BulkIterationNode template, String nodeName, Channel input, BulkPartialSolutionPlanNode pspn, PlanNode rootOfStepFunction, PlanNode rootOfTerminationCriterion)
BulkPartialSolutionPlanNode(BulkPartialSolutionNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, DriverStrategy diverStrategy)
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, DriverStrategy diverStrategy, FieldList driverKeyFields1, FieldList driverKeyFields2)
DualInputPlanNode(OptimizerNode template, String nodeName, Channel input1, Channel input2, DriverStrategy diverStrategy, FieldList driverKeyFields1, FieldList driverKeyFields2, boolean[] driverSortOrders)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, DriverStrategy driverStrategy)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, DriverStrategy driverStrategy, FieldList driverKeyFields)
SingleInputPlanNode(OptimizerNode template, String nodeName, Channel input, DriverStrategy driverStrategy, FieldList driverKeyFields, boolean[] driverSortOrders)
SinkJoinerPlanNode(SinkJoiner template, Channel input1, Channel input2)
SinkPlanNode(DataSinkNode template, String nodeName, Channel input) Constructs a new sink candidate node that uses NONE as its local strategy.
SolutionSetPlanNode(SolutionSetNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)
WorksetIterationPlanNode(WorksetIterationNode template, String nodeName, Channel initialSolutionSet, Channel initialWorkset, SolutionSetPlanNode solutionSetPlanNode, WorksetPlanNode worksetPlanNode, PlanNode nextWorkSetPlanNode, PlanNode solutionSetDeltaPlanNode)
WorksetPlanNode(WorksetNode template, String nodeName, GlobalProperties gProps, LocalProperties lProps, Channel initialInput)

Constructor parameters in org.apache.flink.optimizer.plan with type arguments of type Channel

Constructor and Description
NAryUnionPlanNode(BinaryUnionNode template, List<Channel> inputs, GlobalProperties gProps, Costs cumulativeCosts)

Uses of Channel in org.apache.flink.optimizer.traversals

Methods in org.apache.flink.optimizer.traversals with parameters of type Channel

Modifier and Type	Method and Description
void	BinaryUnionReplacer.collect(Channel in, List<Channel> inputs)

Method parameters in org.apache.flink.optimizer.traversals with type arguments of type Channel

Modifier and Type	Method and Description
void	BinaryUnionReplacer.collect(Channel in, List<Channel> inputs)

Uses of Channel in org.apache.flink.optimizer.util

Methods in org.apache.flink.optimizer.util with parameters of type Channel

Modifier and Type	Method and Description
static TypeComparatorFactory<?>	Utils.getShipComparator(Channel channel, ExecutionConfig executionConfig)