Module watermark_filter 

Dynamic watermark filter for scan-level late-data pruning Dynamic watermark filter for scan-level late-data pruning

Pushes a ts >= watermark predicate down to StreamingScanExec so late rows are dropped before expression evaluation. The shared Arc<AtomicI64> watermark is the same one Ring 0 already updates.

Structs

WatermarkDynamicFilter

Dynamic filter that drops rows older than the current watermark.