Module window 

Streaming window plan configuration and fragment encoding (unified execution).

Structs

FloatLiteral

A float literal with bitwise equality so filter ASTs stay Eq-comparable.

ParsedStreamFragment

Parsed streaming window fragment (all window kinds).

WindowAgg

One aggregate in a windowed stream plan.

WindowExecutionSpec

Full specification for a keyed, windowed streaming operator.

Enums

AggFilterCompareOp

Comparison operator inside a WindowAggFilter.

AggFilterValue

Literal value a filter compares a column against.

WindowAggFilter

Typed per-aggregate row predicate for streaming windows.

WindowAggKind

Aggregate function in a streaming window plan.

WindowKind

Window operator kind for streaming execution.

Constants

WINDOW_EXECUTION_SPEC_PREFIX

Versioned prefix for lossless JSON-encoded WindowExecutionSpec values.

Functions

decode_window_execution_spec

Decode a lossless window specification, accepting legacy compact fragments for backward compatibility.

encode_stream_fragment

Encode a window spec as an executor plan fragment description.

encode_window_execution_spec

Validate and losslessly encode a window execution specification.

parse_stream_fragment

Parse stream:tw|sw|ses:... fragment strings.

validate_window_execution_spec

Validate invariants required by all continuous window executors.