Package | Description |
---|---|
org.apache.flink.api.table.expressions | |
org.apache.flink.api.table.plan.logical |
Modifier and Type | Class and Description |
---|---|
class |
ResolvedFieldReference |
class |
UnresolvedFieldReference |
Modifier and Type | Method and Description |
---|---|
Attribute |
Attribute.toAttribute() |
Attribute |
NamedExpression.toAttribute() |
Attribute |
Alias.toAttribute() |
Attribute |
UnresolvedAlias.toAttribute() |
Attribute |
UnresolvedFieldReference.withName(String newName) |
abstract Attribute |
Attribute.withName(String newName) |
Attribute |
ResolvedFieldReference.withName(String newName) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<Attribute> |
Intersect.output() |
abstract scala.collection.Seq<Attribute> |
LogicalNode.output() |
scala.collection.Seq<Attribute> |
Union.output() |
scala.collection.Seq<Attribute> |
Minus.output() |
scala.collection.Seq<Attribute> |
Sort.output() |
scala.collection.Seq<Attribute> |
Filter.output() |
scala.collection.Seq<Attribute> |
Project.output() |
scala.collection.Seq<Attribute> |
Distinct.output() |
scala.collection.Seq<Attribute> |
Join.output() |
scala.collection.Seq<Attribute> |
LogicalRelNode.output() |
scala.collection.Seq<Attribute> |
CatalogNode.output() |
scala.collection.Seq<Attribute> |
Aggregate.output() |
scala.collection.Seq<Attribute> |
AliasNode.output() |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.