(
sql: &str,
ctx: &SessionContext,
)
| 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 | } |
nothing calls this directly
no test coverage detected