Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.functions.utils | |
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) |
Table(TableEnvironment tableEnv,
String udtfCall)
Creates a
Table for a TableFunction call from a String expression. |
Modifier and Type | Method and Description |
---|---|
static LogicalTableFunctionCall |
UserDefinedFunctionUtils.createLogicalFunctionCall(TableEnvironment tableEnv,
String udtf)
Creates a
LogicalTableFunctionCall by parsing a String expression. |
LogicalTableFunctionCall |
UserDefinedFunctionUtils$.createLogicalFunctionCall(TableEnvironment tableEnv,
String udtf)
Creates a
LogicalTableFunctionCall by parsing a String expression. |
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 Expression |
ProjectionTranslator.replaceAggFunctionCall(Expression field,
TableEnvironment tableEnv)
Find and replace UDAGG function Call to AggFunctionCall
|
Expression |
ProjectionTranslator$.replaceAggFunctionCall(Expression field,
TableEnvironment tableEnv)
Find and replace UDAGG function Call to AggFunctionCall
|
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.
|
static scala.collection.Seq<Expression> |
ProjectionTranslator.resolveOverWindows(scala.collection.Seq<Expression> exprs,
OverWindow[] overWindows,
TableEnvironment tEnv) |
scala.collection.Seq<Expression> |
ProjectionTranslator$.resolveOverWindows(scala.collection.Seq<Expression> exprs,
OverWindow[] overWindows,
TableEnvironment tEnv) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.