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 435ebfa [FLINK-20836][runtime] Pass total resource and default slot
resource in registering TaskManager to SlotManager
add 447cc15 [FLINK-20856][table-planner-blink] Introduce
StreamPhysicalGroupWindowAggregate & StreamPhysicalGroupWindowTableAggregate,
and make StreamExecGroupWindowAggregate only extended from ExecNode
add 85b6a3b [FLINK-20856][table-planner-blink] Introduce
StreamPhysicalPythonGroupWindowAggregate, and make
StreamExecPythonGroupWindowAggregate only extended from ExecNode
No new revisions were added by this update.
Summary of changes:
.../stream/StreamExecGroupWindowAggregate.java | 369 +++++++++++++++++++++
...eamPhysicalPythonGroupWindowAggregateRule.java} | 40 +--
.../plan/metadata/FlinkRelMdColumnInterval.scala | 10 +-
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 6 +-
.../FlinkRelMdFilteredColumnInterval.scala | 6 +-
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 4 +-
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 4 +-
.../StreamExecPythonGroupWindowAggregate.scala | 129 +++----
.../StreamExecGroupWindowAggregateBase.scala | 324 ------------------
...la => StreamPhysicalGroupWindowAggregate.scala} | 41 ++-
...> StreamPhysicalGroupWindowAggregateBase.scala} | 46 ++-
... StreamPhysicalGroupWindowTableAggregate.scala} | 45 ++-
...StreamPhysicalPythonGroupWindowAggregate.scala} | 48 +--
.../FlinkChangelogModeInferenceProgram.scala | 6 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 6 +-
.../stream/MiniBatchIntervalInferRule.scala | 4 +-
...> StreamPhysicalGroupWindowAggregateRule.scala} | 24 +-
...eamPhysicalGroupWindowTableAggregateRule.scala} | 34 +-
.../table/planner/plan/utils/AggregateUtil.scala | 2 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 12 +-
.../stream/table/MiniBatchGroupWindowITCase.scala | 17 +-
21 files changed, 595 insertions(+), 582 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupWindowAggregate.java
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecPythonGroupWindowAggregateRule.java
=> StreamPhysicalPythonGroupWindowAggregateRule.java} (79%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/{physical
=> exec}/stream/StreamExecPythonGroupWindowAggregate.scala (78%)
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecGroupWindowAggregateBase.scala
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecGroupWindowAggregate.scala
=> StreamPhysicalGroupWindowAggregate.scala} (66%)
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamPhysicalGroupTableAggregateBase.scala
=> StreamPhysicalGroupWindowAggregateBase.scala} (52%)
copy
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecGroupWindowTableAggregate.scala
=> StreamPhysicalGroupWindowTableAggregate.scala} (63%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecGroupWindowTableAggregate.scala
=> StreamPhysicalPythonGroupWindowAggregate.scala} (64%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecGroupWindowAggregateRule.scala
=> StreamPhysicalGroupWindowAggregateRule.scala} (82%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/{StreamExecGroupWindowTableAggregateRule.scala
=> StreamPhysicalGroupWindowTableAggregateRule.scala} (80%)
