Module streaming_optimizer 

Physical optimizer rule for streaming plan validation. Physical optimizer rule for streaming plan validation.

Detects pipeline-breaking operators (Sort, Final Aggregate) on unbounded inputs and rejects or warns at plan-creation time, before any execution begins.

Structs

StreamingPhysicalValidator

Validates that a physical plan is safe for streaming execution.

Enums

StreamingValidatorMode

How the validator handles streaming plan violations.