Package | Description |
---|---|
org.apache.flink.api.java.table | |
org.apache.flink.api.scala.table | |
org.apache.flink.api.table |
Table API
This package contains the generic part of the Table API. |
org.apache.flink.api.table.plan |
Modifier and Type | Method and Description |
---|---|
<A> DataSet<A> |
JavaBatchTranslator.translate(PlanNode op,
TypeInformation<A> tpe) |
<A> DataStream<A> |
JavaStreamingTranslator.translate(PlanNode op,
TypeInformation<A> tpe) |
Modifier and Type | Method and Description |
---|---|
<O> DataSet<O> |
ScalaBatchTranslator.translate(PlanNode op,
TypeInformation<O> tpe) |
<O> DataStream<O> |
ScalaStreamingTranslator.translate(PlanNode op,
TypeInformation<O> tpe) |
Modifier and Type | Method and Description |
---|---|
PlanNode |
Table.operation() |
Constructor and Description |
---|
Table(PlanNode operation) |
Modifier and Type | Class and Description |
---|---|
class |
Aggregate
Internal operation.
|
class |
As
Operation that gives new names to fields.
|
class |
Filter
Operation that filters out elements that do not match the predicate expression.
|
class |
GroupBy
Grouping operation.
|
class |
Join
Operation that joins two
Table s. |
class |
Root<T>
|
class |
Select
Selection expression.
|
class |
UnionAll
UnionAll operation, union all elements from left and right.
|
Modifier and Type | Method and Description |
---|---|
static PlanNode |
ExpandAggregations.apply(Select select) |
PlanNode |
ExpandAggregations$.apply(Select select) |
PlanNode |
As.input() |
PlanNode |
GroupBy.input() |
PlanNode |
Filter.input() |
PlanNode |
Select.input() |
PlanNode |
Aggregate.input() |
PlanNode |
Join.left() |
PlanNode |
UnionAll.left() |
PlanNode |
Join.right() |
PlanNode |
UnionAll.right() |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<PlanNode> |
As.children() |
scala.collection.Seq<PlanNode> |
GroupBy.children() |
scala.collection.Seq<PlanNode> |
Filter.children() |
scala.collection.Seq<PlanNode> |
Select.children() |
scala.collection.Seq<PlanNode> |
Join.children() |
scala.collection.Seq<PlanNode> |
Aggregate.children() |
scala.collection.Seq<PlanNode> |
UnionAll.children() |
Modifier and Type | Method and Description |
---|---|
abstract <A> Object |
PlanTranslator.translate(PlanNode op,
TypeInformation<A> tpe)
Translates the given Table API
PlanNode back to the underlying representation, i.e,
a DataSet or a DataStream. |
Constructor and Description |
---|
Aggregate(PlanNode input,
scala.collection.Seq<scala.Tuple2<String,Aggregations>> aggregations) |
As(PlanNode input,
scala.collection.Seq<String> names) |
Filter(PlanNode input,
Expression predicate) |
GroupBy(PlanNode input,
scala.collection.Seq<Expression> fields) |
Join(PlanNode left,
PlanNode right) |
Select(PlanNode input,
scala.collection.Seq<Expression> selection) |
UnionAll(PlanNode left,
PlanNode right) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.