feat(over window): generate EOWC stream plan from LogicalOverAgg

[stdrc]

I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.

What's changed and what's your intention?

This PR enables Over Window feature with EMIT ON WINDOW CLOSE. Tracked in #9124.

Checklist For Contributors

• I have written necessary rustdoc comments
• I have added necessary unit tests and integration tests
• I have added fuzzing tests or opened an issue to track them. (Optional, recommended for new SQL features Sqlsmith: Sql feature generation #7934).
• I have demonstrated that backward compatibility is not broken by breaking changes and created issues to track deprecated features to be removed in the future. (Please refer to the issue)
• All checks passed in ./risedev check (or alias, ./risedev c)

Checklist For Reviewers

• I have requested macro/micro-benchmarks as this PR can affect performance substantially, and the results are shown.

Documentation

Types of user-facing changes

• SQL commands, functions, and operators

Release note

Support Over Window (a.k.a Over Aggregation or Window Function) with EMIT ON WINDOW CLOSE. Currently only support windows partitioned by at least one column and ordered by only single watermark column.

Example:

CREATE SOURCE t (a TIMESTAMP, b INT, WATERMARK FOR a AS a - INTERVAL '5 minutes') WITH ...;
CREATE MATERIALIZED VIEW mv EMIT ON WINDOW CLOSE AS
SELECT
    window_start,
    lag(b) OVER (PARTITION BY window_start ORDER BY a),
    max(b) OVER (PARTITION BY window_start ORDER BY a ROWS BETWEEN 10 PRECEDING AND CURRENT ROW)
FROM tumble(t, a, INTERVAL '1 hour');

Window functions supported by far:

• lag and lead with constant offset
• aggregate functions

Window frame types supported by far:

• ROWS without exclusion clause

[codecov]

Codecov Report

Merging #9597 (29f4cad) into main (2ff33a7) will increase coverage by 0.07%.
The diff coverage is 81.91%.

@@            Coverage Diff             @@
##             main    #9597      +/-   ##
==========================================
+ Coverage   70.83%   70.90%   +0.07%     
==========================================
  Files        1238     1238              
  Lines      207367   207449      +82     
==========================================
+ Hits       146879   147090     +211     
+ Misses      60488    60359     -129     

Flag	Coverage Δ
rust	70.90% <81.91%> (+0.07%)	⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
src/stream/src/from_proto/eowc_over_window.rs	0.00% <0.00%> (ø)
...ontend/src/optimizer/plan_node/logical_over_agg.rs	88.25% <78.78%> (+2.65%)	⬆️
...end/src/optimizer/plan_node/generic/over_window.rs	89.84% <94.44%> (+15.06%)	⬆️
...rc/frontend/src/optimizer/plan_node/stream_sort.rs	98.64% <100.00%> (+3.06%)	⬆️

... and 13 files with indirect coverage changes

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

[soundOfDestiny]

lgtm

[soundOfDestiny]

yet another inconsistent op

[chenzl25]

richardchien wants to merge 6 commits into rc/eowc-keyword from rc/logical-over-window-to-stream

Why not merge into the main branch?

[stdrc]

Why not merge into the main branch?

Because this PR depends on #9622. Will merge that first, then this PR will automatically based on main.

[chenzl25]

LGTM