Package | Description |
---|---|
org.apache.flink.table.expressions | |
org.apache.flink.table.plan | |
org.apache.flink.table.plan.logical |
Modifier and Type | Class and Description |
---|---|
class |
Alias |
class |
Attribute |
class |
ResolvedFieldReference |
class |
UnresolvedAlias |
class |
UnresolvedFieldReference |
class |
WindowReference |
Modifier and Type | Method and Description |
---|---|
static scala.util.parsing.combinator.PackratParsers.PackratParser<NamedExpression> |
ExpressionParser.fieldReference() |
scala.util.parsing.combinator.PackratParsers.PackratParser<NamedExpression> |
ExpressionParser$.fieldReference() |
Modifier and Type | Method and Description |
---|---|
static scala.collection.Seq<NamedExpression> |
ProjectionTranslator.extractFieldReferences(scala.collection.Seq<Expression> exprs)
Extract all field references from the given expressions.
|
scala.collection.Seq<NamedExpression> |
ProjectionTranslator$.extractFieldReferences(scala.collection.Seq<Expression> exprs)
Extract all field references 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.
|
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<NamedExpression> |
WindowAggregate.aggregateExpressions() |
scala.collection.Seq<NamedExpression> |
Aggregate.aggregateExpressions() |
scala.collection.Seq<NamedExpression> |
Project.projectList() |
scala.collection.Seq<NamedExpression> |
WindowAggregate.propertyExpressions() |
static scala.Option<NamedExpression> |
Intersect.resolveReference(TableEnvironment tableEnv,
String name) |
scala.Option<NamedExpression> |
LogicalNode.resolveReference(TableEnvironment tableEnv,
String name)
Resolves the given strings to a
NamedExpression using the input from all child
nodes of this LogicalPlan. |
static scala.Option<NamedExpression> |
Union.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Minus.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Sort.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
LogicalTableFunctionCall.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Filter.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Project.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Distinct.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Join.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Limit.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
LogicalRelNode.resolveReference(TableEnvironment tableEnv,
String name) |
scala.Option<NamedExpression> |
WindowAggregate.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
CatalogNode.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
Aggregate.resolveReference(TableEnvironment tableEnv,
String name) |
static scala.Option<NamedExpression> |
AliasNode.resolveReference(TableEnvironment tableEnv,
String name) |
Constructor and Description |
---|
Aggregate(scala.collection.Seq<Expression> groupingExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
Project(scala.collection.Seq<NamedExpression> projectList,
LogicalNode child) |
WindowAggregate(scala.collection.Seq<Expression> groupingExpressions,
LogicalWindow window,
scala.collection.Seq<NamedExpression> propertyExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
WindowAggregate(scala.collection.Seq<Expression> groupingExpressions,
LogicalWindow window,
scala.collection.Seq<NamedExpression> propertyExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.