flink

a4c18945 - [FLINK-37647] Add NonTimeRowsUnboundedPrecedingFunction for OverAggregate (#26424)

[FLINK-37647] Add NonTimeRowsUnboundedPrecedingFunction for OverAggregate (#26424) * [FLINK-37647] Refactor non-time range unbounded preceding function * [FLINK-37647] Add NonTimeRowsUnboundedPrecedingFunction for OverAggregate - Non-time attribute over aggregates can support retract mode - Add support for rows syntax - Example: INSERT INTO sink_t SELECT key, val, ts, SUM(val) OVER ( PARTITION BY key ORDER BY <NON-TIME-ATTRIBUTE> ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW) AS sum_val FROM source_t * [FLINK-37647] Add restore tests for NonTimeRowsUnboundedPrecedingFunction