Uses of Class
org.apache.flink.optimizer.dag.TwoInputNode

Packages that use TwoInputNode

Package	Description
org.apache.flink.optimizer.dag
org.apache.flink.optimizer.operators
org.apache.flink.optimizer.plan

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

Subclasses of TwoInputNode in org.apache.flink.optimizer.dag

Modifier and Type	Class	Description
class	BinaryUnionNode	The Optimizer representation of a binary Union.
class	CoGroupNode	The Optimizer representation of a CoGroup operator.
class	CoGroupRawNode	The Optimizer representation of a CoGroupRaw operator.
class	CrossNode	The Optimizer representation of a Cross (Cartesian product) operator.
class	JoinNode	The Optimizer representation of a join operator.
class	OuterJoinNode
class	SinkJoiner	This class represents a utility node that is not part of the actual plan.
class	WorksetIterationNode	A node in the optimizer's program representation for a workset iteration.
static class	WorksetIterationNode.SingleRootJoiner

Methods in org.apache.flink.optimizer.dag that return TwoInputNode

Modifier and Type	Method	Description
TwoInputNode	WorksetIterationNode.getSingleRootOfStepFunction()

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

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

Modifier and Type	Method	Description
DualInputPlanNode	AbstractSortMergeJoinDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	BinaryUnionOpDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CartesianProductDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CoGroupDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CoGroupRawDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	CoGroupWithSolutionSetFirstDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashFullOuterJoinBuildFirstDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashFullOuterJoinBuildSecondDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashJoinBuildFirstProperties.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashJoinBuildSecondProperties.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	HashRightOuterJoinBuildFirstDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	HashRightOuterJoinBuildSecondDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)
abstract DualInputPlanNode	OperatorDescriptorDual.instantiate(Channel in1, Channel in2, TwoInputNode node)
DualInputPlanNode	UtilSinkJoinOpDescriptor.instantiate(Channel in1, Channel in2, TwoInputNode node)

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

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

Modifier and Type	Method	Description
TwoInputNode	DualInputPlanNode.getTwoInputNode()