MCPcopy Create free account
hub / github.com/apache/datafusion / execute_query_without_result_buffering

Method execute_query_without_result_buffering

benchmarks/src/dict.rs:423–435  ·  view source on GitHub ↗
(
        sql: &str,
        ctx: &SessionContext,
    )

Source from the content-addressed store, hash-verified

421 }
422
423 async fn execute_query_without_result_buffering(
424 sql: &str,
425 ctx: &SessionContext,
426 ) -> Result<usize> {
427 let mut row_count = 0;
428 let df = ctx.sql(sql).await?;
429 let physical_plan = df.create_physical_plan().await?;
430 let mut stream = execute_stream(physical_plan, ctx.task_ctx())?;
431 while let Some(batch) = stream.next().await {
432 row_count += batch?.num_rows();
433 }
434 Ok(row_count)
435 }
436}

Callers

nothing calls this directly

Calls 5

execute_streamFunction · 0.85
sqlMethod · 0.80
create_physical_planMethod · 0.45
task_ctxMethod · 0.45
nextMethod · 0.45

Tested by

no test coverage detected