Class | Description |
---|---|
Aggregate |
Internal operation.
|
Aggregate$ | |
As |
Operation that gives new names to fields.
|
As$ | |
ExpandAggregations |
This is used to expand a
Select that contains aggregations. |
ExpandAggregations$ |
This is used to expand a
Select that contains aggregations. |
Filter |
Operation that filters out elements that do not match the predicate expression.
|
Filter$ | |
GroupBy |
Grouping operation.
|
GroupBy$ | |
Join |
Operation that joins two
Table s. |
Join$ | |
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. |
Root<T> | |
Root$ | |
Select |
Selection expression.
|
Select$ | |
UnionAll |
UnionAll operation, union all elements from left and right.
|
UnionAll$ |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.