This is an automated email from the ASF dual-hosted git repository.
ron pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 78e31f0dcc4 [FLINK-34144][docs] Update the documentation about dynamic
source parallelism inference
new 65f02285315 [FLINK-34100][table] Add function getDescription for
internal interface WindowAssigner
new de4e9e7382e [FLINK-34100][table] Extract a
WindowTableFunctionOperatorBase from WindowTableFunctionOperator to prepare for
introducing unaligned window table function
new 9a22ff7e961 [FLINK-34100][table] Introduce
UnalignedWindowTableFunctionOperator for unaligned window
new f1871fc31aa [FLINK-34100][table] Support session window table function
without pulling up with window agg
new bab14f9fabe [FLINK-34100][table] Fix the window table function outputs
wrong row kind
new 80f6e063310 [FLINK-34100][table] Merge SlicingWindowOperator and
UnslicingWindowOperator
The 6 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:
.../logical/SliceAttachedWindowingStrategy.java | 4 +-
.../table/planner/plan/logical/WindowSpec.java | 5 +-
.../exec/batch/BatchExecWindowTableFunction.java | 10 +
.../exec/common/CommonExecWindowTableFunction.java | 48 +-
.../exec/stream/StreamExecWindowAggregateBase.java | 20 +-
.../exec/stream/StreamExecWindowTableFunction.java | 74 +++
.../plan/utils/WindowTableFunctionUtil.java | 10 +
.../plan/stream/sql/agg/WindowAggregateTest.xml | 130 +++++
.../plan/batch/sql/WindowTableFunctionTest.scala | 27 +
.../plan/stream/sql/agg/WindowAggregateTest.scala | 10 +-
.../runtime/stream/sql/WindowAggregateITCase.scala | 37 ++
.../stream/sql/WindowTableFunctionITCase.scala | 104 +++-
.../aggregate/window/WindowAggOperatorBuilder.java | 46 +-
.../processors/UnsliceWindowAggProcessor.java | 10 +-
.../RowTimeWindowDeduplicateOperatorBuilder.java | 10 +-
.../rank/window/WindowRankOperatorBuilder.java | 8 +-
.../internal/MergingWindowProcessFunction.java | 84 ++-
.../groupwindow/operator/WindowOperator.java | 16 +-
...dowOperatorBase.java => WindowAggOperator.java} | 10 +-
.../window/tvf/common/WindowAssigner.java | 7 +-
.../AlignedWindowTableFunctionOperator.java | 71 +++
.../UnalignedWindowTableFunctionOperator.java | 606 +++++++++++++++++++++
...r.java => WindowTableFunctionOperatorBase.java} | 78 +--
.../window/tvf/slicing/SliceAssigner.java | 2 +-
.../window/tvf/slicing/SliceAssigners.java | 35 ++
.../window/tvf/slicing/SlicingWindowOperator.java | 63 ---
.../window/tvf/slicing/SlicingWindowProcessor.java | 31 +-
.../window/tvf/unslicing/UnsliceAssigner.java | 3 +-
.../window/tvf/unslicing/UnsliceAssigners.java | 136 +++++
.../tvf/unslicing/UnslicingWindowOperator.java | 45 --
.../tvf/unslicing/UnslicingWindowProcessor.java | 12 +-
.../window/SlicingWindowAggOperatorTest.java | 108 ++--
.../window/UnslicingWindowAggOperatorTest.java | 95 ++--
.../window/WindowAggOperatorTestBase.java | 4 +-
.../RowTimeWindowDeduplicateOperatorTest.java | 8 +-
.../rank/window/WindowRankOperatorTest.java | 10 +-
...=> AlignedWindowTableFunctionOperatorTest.java} | 147 ++---
.../UnalignedWindowTableFunctionOperatorTest.java | 567 +++++++++++++++++++
.../WindowTableFunctionOperatorTestBase.java | 102 ++++
39 files changed, 2367 insertions(+), 426 deletions(-)
rename
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/common/{WindowOperatorBase.java
=> WindowAggOperator.java} (96%)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/AlignedWindowTableFunctionOperator.java
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/UnalignedWindowTableFunctionOperator.java
rename
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/operator/{WindowTableFunctionOperator.java
=> WindowTableFunctionOperatorBase.java} (65%)
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/slicing/SlicingWindowOperator.java
delete mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window/tvf/unslicing/UnslicingWindowOperator.java
rename
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/window/tvf/operator/{WindowTableFunctionOperatorTest.java
=> AlignedWindowTableFunctionOperatorTest.java} (78%)
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/window/tvf/operator/UnalignedWindowTableFunctionOperatorTest.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/window/tvf/operator/WindowTableFunctionOperatorTestBase.java
