Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.plan | |
org.apache.flink.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.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.
|
static scala.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> |
ProjectionTranslator.extractAggregationsAndProperties(scala.collection.Seq<Expression> exprs,
TableEnvironment tableEnv)
Extracts and deduplicates all aggregation and window property expressions (zero, one, or more)
from the given expressions.
|
scala.Tuple2<scala.collection.immutable.Map<Expression,String>,scala.collection.immutable.Map<Expression,String>> |
ProjectionTranslator$.extractAggregationsAndProperties(scala.collection.Seq<Expression> exprs,
TableEnvironment tableEnv)
Extracts and deduplicates all aggregation and window property expressions (zero, one, or more)
from the given expressions.
|
static scala.collection.Seq<NamedExpression> |
ProjectionTranslator.replaceAggregationsAndProperties(scala.collection.Seq<Expression> exprs,
TableEnvironment tableEnv,
scala.collection.immutable.Map<Expression,String> aggNames,
scala.collection.immutable.Map<Expression,String> propNames)
Replaces expressions with deduplicated aggregations and properties.
|
scala.collection.Seq<NamedExpression> |
ProjectionTranslator$.replaceAggregationsAndProperties(scala.collection.Seq<Expression> exprs,
TableEnvironment tableEnv,
scala.collection.immutable.Map<Expression,String> aggNames,
scala.collection.immutable.Map<Expression,String> propNames)
Replaces expressions with deduplicated aggregations and properties.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.