Skip to main content

compile_streaming_window_sql

Function compile_streaming_window_sql 

Source
pub fn compile_streaming_window_sql(sql: &str) -> SqlResult<StreamingWindowPlan>
Expand description

Compile a windowed streaming SQL query into a StreamingWindowPlan.

Returns SqlError::Unsupported when the query is not a recognised keyed windowed aggregation.

The compile is one shared TVF rewrite + one parse: rewrite_window_tvfs (the same rewrite batch uses) turns the window TVF into a _tvf_window subquery, then the rewritten SQL is parsed once with the front-door dialect and both the window parameters and the key/aggregates are derived from that single parsed plan.