Function write_commit_read

crates/integration_tests/tests/append_tables.rs:128–147

Write batches → commit → scan → read, return all batches.

(table: &Table, batches: Vec<RecordBatch>)

/// Write batches → commit → scan → read, return all batches.
async fn write_commit_read(table: &Table, batches: Vec<RecordBatch>) -> Vec<RecordBatch> {
    let wb = table.new_write_builder();
    let mut tw = wb.new_write().unwrap();
    for batch in &batches {
        tw.write_arrow_batch(batch).await.unwrap();
    }
    wb.new_commit()
        .commit(tw.prepare_commit().await.unwrap())
        .await
        .unwrap();

    let rb = table.new_read_builder();
    let plan = rb.new_scan().plan().await.unwrap();
    let read = rb.new_read().unwrap();
    read.to_arrow(plan.splits())
        .unwrap()
        .try_collect()
        .await
        .unwrap()
}

// ---------------------------------------------------------------------------
// Unpartitioned, bucket = -1 (default)