Function load_csv

datafusion/core/benches/csv_load.rs:33–41

(
    ctx: Arc<Mutex<SessionContext>>,
    rt: &Runtime,
    path: &str,
    options: CsvReadOptions,
)

#[expect(clippy::needless_pass_by_value)]
fn load_csv(
    ctx: Arc<Mutex<SessionContext>>,
    rt: &Runtime,
    path: &str,
    options: CsvReadOptions,
) {
    let df = rt.block_on(ctx.lock().read_csv(path, options)).unwrap();
    black_box(rt.block_on(df.collect()).unwrap());
}

fn create_context() -> Result<Arc<Mutex<SessionContext>>> {
    let ctx = SessionContext::new();