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 5351203 [hotfix][tests] Remove ProgrammedSlotProvider
new 53a888c [FLINK-20737][table-planner-blink] Use RowType instead of
RelDataType when building aggregate info
new 683a2a7 [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalGroupAggregate, and make StreamExecGroupAggregate only extended
from ExecNode
new a44285a [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalPythonGroupAggregate, and make StreamExecPythonGroupAggregate
only extended from ExecNode
new fa64127 [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalLocalGroupAggregate, and make StreamExecLocalGroupAggregate only
extended from ExecNode
new 85e9f80 [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalGlobalGroupAggregate, and make StreamExecGlobalGroupAggregate
only extended from ExecNode
new 1eaf54b [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalIncrementalGroupAggregate, and make
StreamExecIncrementalGroupAggregate only extended from ExecNode
new c96d1ff [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalGroupTableAggregate, and make StreamExecGroupTableAggregate only
extended from ExecNode
new 4541707 [FLINK-20737][table-planner-blink] Introduce
StreamPhysicalPythonGroupTableAggregate, and make
StreamExecPythonGroupTableAggregate only extended from ExecNode
The 8 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:
.../stream/StreamExecGlobalGroupAggregate.java | 226 +++++++++++++++++++++
.../exec/stream/StreamExecGroupAggregate.java | 202 ++++++++++++++++++
.../exec/stream/StreamExecGroupTableAggregate.java | 166 +++++++++++++++
.../StreamExecIncrementalGroupAggregate.java | 188 +++++++++++++++++
.../exec/stream/StreamExecLocalGroupAggregate.java | 129 ++++++++++++
.../batch/BatchExecPythonAggregateRule.java | 5 +-
.../batch/BatchExecPythonWindowAggregateRule.java | 5 +-
...=> StreamPhysicalPythonGroupAggregateRule.java} | 22 +-
...reamPhysicalPythonGroupTableAggregateRule.java} | 21 +-
.../table/planner/codegen/MatchCodeGenerator.scala | 2 +-
.../plan/metadata/FlinkRelMdColumnInterval.scala | 37 ++--
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 6 +-
.../FlinkRelMdFilteredColumnInterval.scala | 10 +-
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 10 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 6 +-
.../common/CommonExecPythonAggregate.scala} | 8 +-
.../stream/StreamExecPythonGroupAggregate.scala | 114 ++++-------
.../StreamExecPythonGroupTableAggregate.scala | 89 ++++----
.../batch/BatchExecHashAggregateBase.scala | 2 +-
.../batch/BatchExecHashWindowAggregateBase.scala | 2 +-
.../physical/batch/BatchExecOverAggregate.scala | 18 +-
.../batch/BatchExecPythonGroupAggregate.scala | 6 +-
.../BatchExecPythonGroupWindowAggregate.scala | 6 +-
.../batch/BatchExecPythonOverAggregate.scala | 4 +-
.../batch/BatchExecSortAggregateBase.scala | 2 +-
.../batch/BatchExecSortWindowAggregateBase.scala | 2 +-
.../stream/StreamExecGlobalGroupAggregate.scala | 207 -------------------
.../physical/stream/StreamExecGroupAggregate.scala | 192 -----------------
.../stream/StreamExecGroupTableAggregate.scala | 140 -------------
.../StreamExecGroupWindowAggregateBase.scala | 2 +-
.../StreamExecIncrementalGroupAggregate.scala | 205 -------------------
.../stream/StreamExecLocalGroupAggregate.scala | 142 -------------
.../physical/stream/StreamExecOverAggregate.scala | 8 +-
.../StreamExecPythonGroupWindowAggregate.scala | 4 +-
.../stream/StreamExecPythonOverAggregate.scala | 13 +-
.../StreamPhysicalGlobalGroupAggregate.scala | 108 ++++++++++
.../stream/StreamPhysicalGroupAggregate.scala | 97 +++++++++
...cala => StreamPhysicalGroupAggregateBase.scala} | 2 +-
.../stream/StreamPhysicalGroupTableAggregate.scala | 76 +++++++
...=> StreamPhysicalGroupTableAggregateBase.scala} | 13 +-
.../StreamPhysicalIncrementalGroupAggregate.scala | 132 ++++++++++++
.../stream/StreamPhysicalLocalGroupAggregate.scala | 103 ++++++++++
...la => StreamPhysicalPythonGroupAggregate.scala} | 55 +++--
.../StreamPhysicalPythonGroupTableAggregate.scala | 76 +++++++
.../FlinkChangelogModeInferenceProgram.scala | 12 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 8 +-
.../physical/batch/BatchExecAggRuleBase.scala | 2 +-
.../physical/batch/BatchExecHashAggRule.scala | 4 +-
.../batch/BatchExecOverAggregateRule.scala | 4 +-
.../physical/batch/BatchExecSortAggRule.scala | 4 +-
.../batch/BatchExecWindowAggregateRule.scala | 2 +-
.../physical/batch/EnforceLocalAggRuleBase.scala | 5 +-
.../physical/stream/IncrementalAggregateRule.scala | 118 ++++-------
...cala => StreamPhysicalGroupAggregateRule.scala} | 19 +-
...=> StreamPhysicalGroupTableAggregateRule.scala} | 23 ++-
.../stream/TwoStageOptimizedAggregateRule.scala | 97 ++++-----
.../planner/plan/utils/AggFunctionFactory.scala | 46 ++---
.../table/planner/plan/utils/AggregateUtil.scala | 213 ++++++++++++-------
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 60 +++---
.../plan/stream/table/PythonAggregateTest.scala | 5 +-
60 files changed, 2045 insertions(+), 1440 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGlobalGroupAggregate.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupAggregate.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupTableAggregate.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecIncrementalGroupAggregate.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLocalGroupAggregate.java
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecPythonGroupAggregateRule.java
=> StreamPhysicalPythonGroupAggregateRule.java} (88%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecPythonGroupTableAggregateRule.java
=> StreamPhysicalPythonGroupTableAggregateRule.java} (87%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{common/CommonPythonAggregate.scala
=> exec/common/CommonExecPythonAggregate.scala} (98%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{physical
=> exec}/stream/StreamExecPythonGroupAggregate.scala (65%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{physical
=> exec}/stream/StreamExecPythonGroupTableAggregate.scala (72%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecGlobalGroupAggregate.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecGroupAggregate.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecGroupTableAggregate.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecIncrementalGroupAggregate.scala
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecLocalGroupAggregate.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalGlobalGroupAggregate.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalGroupAggregate.scala
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecGroupAggregateBase.scala
=> StreamPhysicalGroupAggregateBase.scala} (98%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalGroupTableAggregate.scala
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecGroupTableAggregateBase.scala
=> StreamPhysicalGroupTableAggregateBase.scala} (85%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalIncrementalGroupAggregate.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalLocalGroupAggregate.scala
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecGroupTableAggregateBase.scala
=> StreamPhysicalPythonGroupAggregate.scala} (52%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalPythonGroupTableAggregate.scala
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecGroupAggregateRule.scala
=> StreamPhysicalGroupAggregateRule.scala} (88%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecGroupTableAggregateRule.scala
=> StreamPhysicalGroupTableAggregateRule.scala} (84%)
