Package | Description |
---|---|
org.apache.flink.api.table | |
org.apache.flink.api.table.plan.logical |
Modifier and Type | Method and Description |
---|---|
LogicalNode |
Table.logicalPlan() |
Constructor and Description |
---|
Table(TableEnvironment tableEnv,
LogicalNode logicalPlan) |
Modifier and Type | Class and Description |
---|---|
class |
Aggregate |
class |
AliasNode |
class |
BinaryNode |
class |
CatalogNode |
class |
Distinct |
class |
Filter |
class |
Intersect |
class |
Join |
class |
LeafNode |
class |
LogicalRelNode
Wrapper for valid logical plans generated from SQL String.
|
class |
Minus |
class |
Project |
class |
Sort |
class |
UnaryNode |
class |
Union |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<LogicalNode> |
BinaryNode.children() |
scala.collection.Seq<LogicalNode> |
LeafNode.children() |
scala.collection.Seq<LogicalNode> |
UnaryNode.children() |
Constructor and Description |
---|
Aggregate(scala.collection.Seq<Expression> groupingExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
AliasNode(scala.collection.Seq<Expression> aliasList,
LogicalNode child) |
Distinct(LogicalNode child) |
Filter(Expression condition,
LogicalNode child) |
Intersect(LogicalNode left,
LogicalNode right,
boolean all) |
Join(LogicalNode left,
LogicalNode right,
JoinType joinType,
scala.Option<Expression> condition) |
Minus(LogicalNode left,
LogicalNode right,
boolean all) |
Project(scala.collection.Seq<NamedExpression> projectList,
LogicalNode child) |
Sort(scala.collection.Seq<Ordering> order,
LogicalNode child) |
Union(LogicalNode left,
LogicalNode right,
boolean all) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.