Package | Description |
---|---|
org.apache.flink.api.table.expressions | |
org.apache.flink.api.table.plan | |
org.apache.flink.api.table.plan.logical |
Modifier and Type | Class and Description |
---|---|
class |
Alias |
class |
Attribute |
class |
ResolvedFieldReference |
class |
UnresolvedAlias |
class |
UnresolvedFieldReference |
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.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.
|
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<NamedExpression> |
Aggregate.aggregateExpressions() |
scala.collection.Seq<NamedExpression> |
Project.projectList() |
scala.Option<NamedExpression> |
LogicalNode.resolveReference(String name)
Resolves the given strings to a
NamedExpression using the input from all child
nodes of this LogicalPlan. |
Constructor and Description |
---|
Aggregate(scala.collection.Seq<Expression> groupingExpressions,
scala.collection.Seq<NamedExpression> aggregateExpressions,
LogicalNode child) |
Project(scala.collection.Seq<NamedExpression> projectList,
LogicalNode child) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.