Module streaming_window_plan 

Compile a windowed streaming SQL query into a WindowExecutionSpec.

Supports the canonical keyed windowed-aggregation shape:

SELECT key, AGG(col) AS out [, ...]
FROM TUMBLE(TABLE src, DESCRIPTOR(ts), <size>)   -- or HOP / SESSION
GROUP BY key, window_start, window_end

The streaming engine uses the resulting WindowExecutionSpec to drive the dataflow ContinuousWindowExecutor. The window operator computes the aggregation itself, so the SELECT/GROUP BY is only mined for the grouping key column and the aggregate list — the rest of the query shape is the window TVF, which find_window_tvf already parses.

Structs

StreamingWindowPlan

A compiled windowed streaming plan: the operator spec plus the name of the source table the window reads from.

Functions

compile_streaming_window_sql

Compile a windowed streaming SQL query into a StreamingWindowPlan.

is_windowed_streaming_sql

Returns true when sql contains a TUMBLE/HOP/SESSION window TVF.