pub(super) fn plan_auto_strategy( session: &SessionImpl, plan: StreamPlanRef, ) -> HashMap<u32, Uint32Vector>