This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 882efcb [FLINK-11534] [container] Allow ExecutionMode configuration
new 6ba42b9 [FLINK-11884][table] Ported aggregation validation on top of
Expressions
new 693e68f [FLINK-11884][table] Ported filter validation on top of
Expressions
new 25f1d51 [FLINK-11884][table] Ported Minus, Intersect, Union
validation on top of Expressions
new c0d14bd [FLINK-11884][table] Ported join validation on top of
Expressions
new bf15298 [FLINK-11884][table] Skeleton for transforming operations to
RelNodes
new 2c45c42 [FLINK-11884][table] AggregateTableOperation construction &
transformation to RelNodes
new 2e4e20c [FLINK-11884][table] DistinctTableOperation &
FilterTableOperation construction & transformation to RelNodes
new 7c6a637 [FLINK-11884][table] SortTableOperation construction &
transformation to RelNodes
new 6ac692d [FLINK-11884][table] CalculatedTableOperation construction &
transformation to RelNodes
new 099121c [FLINK-11884][table] CatalogTableOperation construction &
transformation to RelNodes
new 6b48a30 [FLINK-11884][table] PlannerTableOperation construction &
transformation to RelNodes
new 665e3f4 [FLINK-11884][table] WindowAggregateTableOperation
construction & tranformation to RelNodes
new df59135 [FLINK-11884][table] JoinTableOperation construction &
tranformation to RelNodes
The 16369 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../table/expressions/ApiExpressionUtils.java | 21 +-
.../table/operations/AggregateTableOperation.java | 73 +++
.../table/operations/CalculatedTableOperation.java | 78 +++
...leOperation.java => CatalogTableOperation.java} | 38 +-
...eOperation.java => DistinctTableOperation.java} | 32 +-
...bleOperation.java => FilterTableOperation.java} | 40 +-
.../flink/table/operations/JoinTableOperation.java | 117 ++++
.../operations/OperationExpressionsUtils.java | 5 +-
.../table/operations/ProjectTableOperation.java | 66 +++
.../flink/table/operations/SetTableOperation.java | 87 +++
.../flink/table/operations/SortTableOperation.java | 83 +++
.../flink/table/operations/TableOperation.java | 6 +
.../operations/TableOperationDefaultVisitor.java | 87 +++
...leOperation.java => TableOperationVisitor.java} | 32 +-
.../operations/WindowAggregateTableOperation.java | 206 +++++++
.../expressions/ExpressionDefaultVisitor.java | 61 ++
.../flink/table/expressions/ExpressionUtils.java | 65 +++
.../table/expressions/ExpressionResolver.java | 19 +-
.../operations/AggregateOperationFactory.java | 468 ++++++++++++++++
.../table/operations/AliasOperationUtils.java | 4 +-
.../table/operations/CalculatedTableFactory.java | 60 +-
.../table/operations/JoinOperationFactory.java | 148 +++++
.../operations/ProjectionOperationFactory.java | 106 ++--
.../table/operations/SetOperationFactory.java | 106 ++++
.../table/operations/SortOperationFactory.java | 76 ++-
.../flink/table/plan/TableOperationConverter.java | 365 ++++++++++++
.../apache/flink/table/api/TableEnvironment.scala | 41 +-
.../org/apache/flink/table/api/tableImpl.scala | 6 +-
.../flink/table/calcite/FlinkRelBuilder.scala | 37 +-
.../table/calcite/FlinkRelBuilderFactory.scala | 12 +-
.../org/apache/flink/table/expressions/call.scala | 1 -
.../flink/table/expressions/fieldExpression.scala | 16 +
.../apache/flink/table/expressions/subquery.scala | 4 +-
.../table/operations/OperationTreeBuilder.scala | 166 ++----
.../table/operations/PlannerTableOperation.java | 71 +++
.../flink/table/plan/logical/LogicalNode.scala | 74 ---
.../flink/table/plan/logical/LogicalWindow.scala | 45 --
.../flink/table/plan/logical/Resolvable.scala | 43 --
.../flink/table/plan/logical/groupWindows.scala | 172 +-----
.../flink/table/plan/logical/operators.scala | 619 ---------------------
.../LogicalCorrelateToTemporalTableJoinRule.scala | 7 +-
.../table/validation/AggregateValidationTest.scala | 9 +
.../validation/GroupWindowValidationTest.scala | 138 ++++-
.../validation/ColumnFunctionsValidationTest.scala | 2 +-
44 files changed, 2652 insertions(+), 1260 deletions(-)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/AggregateTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/CalculatedTableOperation.java
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{TableOperation.java
=> CatalogTableOperation.java} (55%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{TableOperation.java
=> DistinctTableOperation.java} (61%)
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{TableOperation.java
=> FilterTableOperation.java} (53%)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/JoinTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ProjectTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SetTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SortTableOperation.java
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/TableOperationDefaultVisitor.java
copy
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{TableOperation.java
=> TableOperationVisitor.java} (55%)
create mode 100644
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/WindowAggregateTableOperation.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ExpressionDefaultVisitor.java
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ExpressionUtils.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/operations/AggregateOperationFactory.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/operations/JoinOperationFactory.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/operations/SetOperationFactory.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/TableOperationConverter.java
create mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/operations/PlannerTableOperation.java
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/LogicalNode.scala
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/LogicalWindow.scala
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/Resolvable.scala
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
