Function collect_query

crates/integrations/datafusion/tests/read_tables.rs:94–99

(
    sql: &str,
)

}

async fn collect_query(
    sql: &str,
) -> datafusion::error::Result<Vec<datafusion::arrow::record_batch::RecordBatch>> {
    let ctx = create_context().await;
    ctx.sql(sql).await?.collect().await
}

async fn create_physical_plan(sql: &str) -> datafusion::error::Result<Arc<dyn ExecutionPlan>> {
    let ctx = create_context().await;