Function is_stateless_flow_plan 

fn is_stateless_flow_plan(plan: &LogicalPlan) -> bool

The stateless streaming runtime accepts only a single source scan wrapped by projections and filters. Keep this check local to the operator: the flow validator is intentionally private to the flow crate.