You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2025/04/01 13:24:58 UTC
(flink) branch master updated (60041948a63 -> e06fddc9554)

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 60041948a63 [FLINK-37547][docs] Document PTFs
     add e06fddc9554 [FLINK-19059]: Add NonTimeRangeUnboundedPrecedingFunction for OverAggregate

No new revisions were added by this update.

Summary of changes:
 .../docs/dev/table/sql/queries/over-agg.md         |    9 +-
 .../content/docs/dev/table/sql/queries/over-agg.md |   14 +-
 .../nodes/exec/stream/StreamExecOverAggregate.java |  259 +++--
 .../StreamNonDeterministicUpdatePlanVisitor.java   |   11 +-
 .../FlinkChangelogModeInferenceProgram.scala       |   38 +-
 .../NonDeterministicUpdateAnalyzerTest.java        |  102 ++
 .../nodes/exec/stream/OverWindowRestoreTest.java   |   22 +-
 .../nodes/exec/stream/OverWindowTestPrograms.java  | 1005 ++++++++++++++++++++
 ...e-non-time-range-unbounded-avg-append-mode.json |  237 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 19033 bytes
 ...-range-unbounded-multiple-aggs-append-mode.json |  244 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 20499 bytes
 ...e-non-time-range-unbounded-sum-append-mode.json |  227 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 19024 bytes
 ...n-time-range-unbounded-sum-no-partition-by.json |  226 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 17065 bytes
 ...nbounded-sum-retract-mode-sink-primary-key.json |  238 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 19633 bytes
 ...ounded-sum-retract-mode-source-primary-key.json |  233 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 19550 bytes
 ...ource-sink-primary-key-partition-by-non-pk.json |  243 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 19974 bytes
 ...d-sum-retract-mode-source-sink-primary-key.json |  307 ++++++
 .../savepoint/_metadata                            |  Bin 0 -> 19929 bytes
 ...-non-time-range-unbounded-sum-retract-mode.json |  227 +++++
 .../savepoint/_metadata                            |  Bin 0 -> 19539 bytes
 .../NonTimeRangeUnboundedPrecedingFunction.java    |  727 ++++++++++++++
 .../runtime/operators/over/TimeAttribute.java      |   11 +-
 ...NonTimeRangeUnboundedPrecedingFunctionTest.java | 1003 +++++++++++++++++++
 29 files changed, 5276 insertions(+), 107 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-avg-append-mode/plan/over-aggregate-non-time-range-unbounded-avg-append-mode.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-avg-append-mode/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-multiple-aggs-append-mode/plan/over-aggregate-non-time-range-unbounded-multiple-aggs-append-mode.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-multiple-aggs-append-mode/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-append-mode/plan/over-aggregate-non-time-range-unbounded-sum-append-mode.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-append-mode/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-no-partition-by/plan/over-aggregate-non-time-range-unbounded-sum-no-partition-by.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-no-partition-by/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-sink-primary-key/plan/over-aggregate-non-time-range-unbounded-sum-retract-mode-sink-primary-key.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-sink-primary-key/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-primary-key/plan/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-primary-key.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-primary-key/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-sink-primary-key-partition-by-non-pk/plan/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-sink-primary-key-partition-by-non-pk.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-sink-primary-key-partition-by-non-pk/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-sink-primary-key/plan/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-sink-primary-key.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode-source-sink-primary-key/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode/plan/over-aggregate-non-time-range-unbounded-sum-retract-mode.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-over-aggregate_1/over-aggregate-non-time-range-unbounded-sum-retract-mode/savepoint/_metadata
 create mode 100644 flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunction.java
 copy flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/InitializationStatus.java => flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/TimeAttribute.java (80%)
 create mode 100644 flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunctionTest.java