Function plan_sql

datafusion/core/src/physical_planner.rs:3394–3397

(query: &str)

    }

    async fn plan_sql(query: &str) -> Result<Arc<dyn ExecutionPlan>> {
        let ctx = SessionContext::new();
        ctx.sql(query).await?.create_physical_plan().await
    }

    async fn collect_sql(query: &str) -> Result<Vec<RecordBatch>> {
        let ctx = SessionContext::new();