Function plan_and_collect

datafusion/core/tests/sql/mod.rs:126–128

Execute SQL and return results as a RecordBatch

(ctx: &SessionContext, sql: &str)

/// Execute SQL and return results as a RecordBatch
async fn plan_and_collect(ctx: &SessionContext, sql: &str) -> Result<Vec<RecordBatch>> {
    ctx.sql(sql).await?.collect().await
}

/// Execute query and return results as a Vec of RecordBatches
async fn execute_to_batches(ctx: &SessionContext, sql: &str) -> Vec<RecordBatch> {