This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c0f72aa [hotfix] add scala note to spa docs
new 2906582 [FLINK-20857][table-planner-blink] Rename
BatchExecWindowAggregateBase to BatchPhysicalWindowAggregateBase and do some
refactoring
new a8e591a [FLINK-20857][table-planner-blink] Introduce
BatchPhysicalHashWindowAggregate & BatchPhysicalLocalHashWindowAggregate, and
make BatchExecHashWindowAggregate only extended from ExecNode
new 36352a3 [FLINK-20857][table-planner-blink] Introduce
BatchPhysicalSortWindowAggregate & BatchPhysicalLocalSortWindowAggregate, and
make BatchExecSortWindowAggregate only extended from ExecNode
new 8184934 [FLINK-20857][table-planner-blink] Introduce
BatchPhysicalPythonGroupWindowAggregate, and make
BatchExecPythonGroupWindowAggregate only extended from ExecNode
The 4 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:
.../exec/batch/BatchExecHashWindowAggregate.java | 149 ++++++++++++++++++++
.../exec/batch/BatchExecSortWindowAggregate.java | 150 +++++++++++++++++++++
...=> BatchPhysicalPythonWindowAggregateRule.java} | 17 ++-
.../agg/batch/HashWindowCodeGenerator.scala | 2 +-
.../agg/batch/SortWindowCodeGenerator.scala | 14 +-
.../codegen/agg/batch/WindowCodeGenerator.scala | 33 ++---
.../metadata/AggCallSelectivityEstimator.scala | 14 +-
.../plan/metadata/FlinkRelMdColumnInterval.scala | 14 +-
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 6 +-
.../plan/metadata/FlinkRelMdDistinctRowCount.scala | 8 +-
.../plan/metadata/FlinkRelMdPopulationSize.scala | 6 +-
.../planner/plan/metadata/FlinkRelMdRowCount.scala | 8 +-
.../plan/metadata/FlinkRelMdSelectivity.scala | 8 +-
.../planner/plan/metadata/FlinkRelMdSize.scala | 22 +--
.../plan/metadata/FlinkRelMdUniqueGroups.scala | 7 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 6 +-
.../BatchExecPythonGroupWindowAggregate.scala | 128 +++++-------------
.../batch/BatchExecSortWindowAggregateBase.scala | 131 ------------------
...cala => BatchPhysicalHashWindowAggregate.scala} | 55 ++++----
... => BatchPhysicalHashWindowAggregateBase.scala} | 75 ++---------
...=> BatchPhysicalLocalHashWindowAggregate.scala} | 50 ++++---
...=> BatchPhysicalLocalSortWindowAggregate.scala} | 48 ++++---
.../BatchPhysicalPythonGroupWindowAggregate.scala | 113 ++++++++++++++++
...cala => BatchPhysicalSortWindowAggregate.scala} | 52 +++----
... => BatchPhysicalSortWindowAggregateBase.scala} | 64 +++------
...cala => BatchPhysicalWindowAggregateBase.scala} | 26 ++--
.../planner/plan/rules/FlinkBatchRuleSets.scala | 4 +-
.../batch/BatchPhysicalSortLimitRule.scala | 8 +-
...cala => BatchPhysicalWindowAggregateRule.scala} | 40 +++---
.../batch/RemoveRedundantLocalHashAggRule.scala | 2 +-
.../batch/RemoveRedundantLocalSortAggRule.scala | 2 +-
.../table/planner/plan/utils/FlinkRelMdUtil.scala | 42 +++---
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 33 ++---
33 files changed, 735 insertions(+), 602 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecHashWindowAggregate.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecSortWindowAggregate.java
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecPythonWindowAggregateRule.java
=> BatchPhysicalPythonWindowAggregateRule.java} (93%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{physical
=> exec}/batch/BatchExecPythonGroupWindowAggregate.scala (59%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecSortWindowAggregateBase.scala
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecHashWindowAggregate.scala
=> BatchPhysicalHashWindowAggregate.scala} (68%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecHashWindowAggregateBase.scala
=> BatchPhysicalHashWindowAggregateBase.scala} (52%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecLocalHashWindowAggregate.scala
=> BatchPhysicalLocalHashWindowAggregate.scala} (67%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecLocalSortWindowAggregate.scala
=> BatchPhysicalLocalSortWindowAggregate.scala} (67%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchPhysicalPythonGroupWindowAggregate.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecSortWindowAggregate.scala
=> BatchPhysicalSortWindowAggregate.scala} (69%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecSortWindowAggregate.scala
=> BatchPhysicalSortWindowAggregateBase.scala} (59%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecWindowAggregateBase.scala
=> BatchPhysicalWindowAggregateBase.scala} (83%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/{BatchExecWindowAggregateRule.scala
=> BatchPhysicalWindowAggregateRule.scala} (93%)
