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 |
Class and Description |
---|
PlanNode
Base class for all Table API operations.
|
PlanTranslator
Base class for translators that transform the logical plan in a
Table to an executable
Flink plan and also for creating a Table from a DataSet or DataStream. |
Class and Description |
---|
PlanNode
Base class for all Table API operations.
|
PlanTranslator
Base class for translators that transform the logical plan in a
Table to an executable
Flink plan and also for creating a Table from a DataSet or DataStream. |
Class and Description |
---|
PlanNode
Base class for all Table API operations.
|
Class and Description |
---|
Aggregate$ |
As$ |
ExpandAggregations$
This is used to expand a
Select that contains aggregations. |
Filter$ |
GroupBy$ |
Join$ |
PlanNode
Base class for all Table API operations.
|
Root$ |
Select
Selection expression.
|
Select$ |
UnionAll$ |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.