pub async fn apply_df_optimizer( plan: LogicalPlan, query_ctx: &QueryContextRef, ) -> Result<LogicalPlan, Error>