Package | Description |
---|---|
org.apache.flink.api.table | |
org.apache.flink.api.table.plan | |
org.apache.flink.api.table.plan.logical |
Modifier and Type | Class and Description |
---|---|
class |
BatchTableEnvironment
The abstract base class for batch TableEnvironments.
|
class |
StreamTableEnvironment
The base class for stream TableEnvironments.
|
Modifier and Type | Method and Description |
---|---|
TableEnvironment |
Table.tableEnv() |
Constructor and Description |
---|
Table(TableEnvironment tableEnv,
LogicalNode logicalPlan) |
Modifier and Type | Method and Description |
---|---|
static scala.Tuple2<Expression,scala.collection.immutable.List<NamedExpression>> |
RexNodeTranslator.extractAggregations(Expression exp,
TableEnvironment tableEnv)
Extracts all aggregation expressions (zero, one, or more) from an expression,
and replaces the original aggregation expressions by field accesses expressions.
|
scala.Tuple2<Expression,scala.collection.immutable.List<NamedExpression>> |
RexNodeTranslator$.extractAggregations(Expression exp,
TableEnvironment tableEnv)
Extracts all aggregation expressions (zero, one, or more) from an expression,
and replaces the original aggregation expressions by field accesses expressions.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.