Module optimizer 

Rule-based logical plan optimizer (filter pushdown, window merge, etc.). Rule-based logical plan optimizer

Applies optimization rules to a LogicalPlan before physical materialization. Rules are applied iteratively (up to MAX_PASSES) until no rule produces changes.

Current Rules

• FilterPushdown: Move filters before windows/aggregates when safe
• TemporalFilterPushdown: Push time-based filters before windows
• WindowMerge: Merge adjacent windows with compatible configurations
• ProjectionPruning: Remove duplicate projections (keep last)

Structs

Optimizer

The plan optimizer: runs a set of rules iteratively until convergence.

Traits

OptimizationRule

A single optimization rule that can transform a logical stream.

Functions

optimize_plan

Convenience function: optimize a plan with default rules.