This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from ba647ff [hotfix][docs] Correct the check for hugo installation in
build_docs.sh
add cf35fe9 [FLINK-21881][table-planner-blink] Support local global
optimization for window aggregation in plan (#15412)
No new revisions were added by this update.
Summary of changes:
...{PlannerWindowEnd.java => PlannerSliceEnd.java} | 10 +-
.../planner/expressions/PlannerWindowProperty.java | 3 +-
...gy.java => SliceAttachedWindowingStrategy.java} | 33 +-
.../logical/WindowAttachedWindowingStrategy.java | 28 +-
.../planner/plan/logical/WindowingStrategy.java | 3 +-
.../stream/StreamExecGlobalWindowAggregate.java | 115 ++
.../stream/StreamExecLocalWindowAggregate.java | 106 ++
.../exec/stream/StreamExecWindowAggregate.java | 86 +-
.../exec/stream/StreamExecWindowAggregateBase.java | 114 ++
.../TwoStageOptimizedWindowAggregateRule.java | 178 +++
.../StreamPhysicalGlobalWindowAggregate.scala | 140 ++
.../StreamPhysicalGroupWindowAggregateBase.scala | 2 +-
.../StreamPhysicalLocalWindowAggregate.scala | 136 ++
.../stream/StreamPhysicalWindowAggregate.scala | 55 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 6 +-
.../table/planner/plan/utils/AggregateUtil.scala | 33 +-
.../table/planner/plan/utils/RelExplainUtil.scala | 93 +-
.../table/planner/plan/utils/WindowUtil.scala | 88 +-
.../stream/jsonplan/WindowAggregateJsonITCase.java | 6 +
.../testEventTimeCumulateWindow.out | 146 +-
.../testEventTimeHopWindow.out | 136 +-
.../testEventTimeTumbleWindow.out | 185 ++-
.../planner/plan/stream/sql/WindowRankTest.xml | 76 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 1522 ++++++++++++++++++--
.../plan/stream/sql/join/WindowJoinTest.xml | 110 +-
.../plan/stream/sql/agg/WindowAggregateTest.scala | 104 +-
.../runtime/stream/sql/WindowAggregateITCase.scala | 6 +
.../stream/sql/WindowDistinctAggregateITCase.scala | 5 +
.../runtime/stream/sql/WindowRankITCase.scala | 5 +
29 files changed, 3071 insertions(+), 459 deletions(-)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/{PlannerWindowEnd.java
=> PlannerSliceEnd.java} (83%)
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/logical/{TimeAttributeWindowingStrategy.java
=> SliceAttachedWindowingStrategy.java} (61%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGlobalWindowAggregate.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecLocalWindowAggregate.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecWindowAggregateBase.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/physical/stream/TwoStageOptimizedWindowAggregateRule.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalGlobalWindowAggregate.scala
create mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalLocalWindowAggregate.scala
