org.apache.flink.api.table.plan

Class Join

java.lang.Object

org.apache.flink.api.table.trees.TreeNode<PlanNode>

org.apache.flink.api.table.plan.PlanNode

org.apache.flink.api.table.plan.Join

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class Join
extends PlanNode
implements scala.Product, scala.Serializable

Operation that joins two Tables. A "filter" and a "select" should be applied after a join operation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Join(PlanNode left, PlanNode right)

Method Summary

Modifier and Type	Method and Description
scala.collection.Seq<PlanNode>	children() List of child nodes that should be considered when doing transformations.
PlanNode	left()
scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>>	outputFields()
PlanNode	right()
String	toString()

Methods inherited from class org.apache.flink.api.table.trees.TreeNode

exists, fastEquals, makeCopy, transformChildrenPost, transformChildrenPre, transformPost, transformPre

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Join

public Join(PlanNode left,
            PlanNode right)

Method Detail

left

public PlanNode left()

right

public PlanNode right()

children

public scala.collection.Seq<PlanNode> children()

Description copied from class: TreeNode

List of child nodes that should be considered when doing transformations. Other values in the Product will not be transformed, only handed through.

Specified by:

children in class TreeNode<PlanNode>

outputFields

public scala.collection.Seq<scala.Tuple2<String,TypeInformation<?>>> outputFields()

Specified by:

outputFields in class PlanNode

toString

public String toString()

Overrides:

toString in class Object