Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.expressions | |
org.apache.flink.table.plan | |
org.apache.flink.table.plan.logical |
Modifier and Type | Method and Description |
---|---|
LogicalNode |
Table.logicalPlan() |
Constructor and Description |
---|
Table(TableEnvironment tableEnv,
LogicalNode logicalPlan) |
Modifier and Type | Method and Description |
---|---|
LogicalTableFunctionCall |
TableFunctionCall.toLogicalTableFunctionCall(LogicalNode child)
Converts an API class to a logical node for planning.
|
Modifier and Type | Method and Description |
---|---|
static scala.collection.Seq<Expression> |
ProjectionTranslator.expandProjectList(scala.collection.Seq<Expression> exprs,
LogicalNode parent,
TableEnvironment tableEnv)
Expands an UnresolvedFieldReference("*") to parent's full project list.
|
scala.collection.Seq<Expression> |
ProjectionTranslator$.expandProjectList(scala.collection.Seq<Expression> exprs,
LogicalNode parent,
TableEnvironment tableEnv)
Expands an UnresolvedFieldReference("*") to parent's full project list.
|
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 |
Limit |
class |
LogicalRelNode
Wrapper for valid logical plans generated from SQL String.
|
class |
LogicalTableFunctionCall
LogicalNode for calling a user-defined table functions.
|
class |
Minus |
class |
Project |
class |
Sort |
class |
UnaryNode |
class |
Union |
class |
WindowAggregate |
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,
boolean correlated) |
Limit(int offset,
int fetch,
LogicalNode child) |
LogicalTableFunctionCall(String functionName,
TableFunction<?> tableFunction,
scala.collection.Seq<Expression> parameters,
TypeInformation<?> resultType,
String[] fieldNames,
LogicalNode child) |
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) |
WindowAggregate(scala.collection.Seq<Expression> groupingExpressions,
LogicalWindow window,
scala.collection.Seq<NamedExpression> propertyExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.