Function get_batches

datafusion/core/tests/dataframe/dataframe_functions.rs:78–80

Executes an expression on the test dataframe as a select.

(expr: Expr)

/// Executes an expression on the test dataframe as a select.
async fn get_batches(expr: Expr) -> Result<Vec<RecordBatch>> {
    get_batches_with_limit(expr, 10).await
}

async fn get_batches_with_limit(expr: Expr, limit: usize) -> Result<Vec<RecordBatch>> {
    let df = create_test_table().await?;