pub async fn execute_sql_stream_async(
receiver: AsyncRecordBatchReceiver,
schema: SchemaRef,
table_name: &str,
sql: &str,
) -> Result<Vec<RecordBatch>, ReadStatError>Expand description
Asynchronously executes SQL from a single-use channel of Arrow batches.
Input is consumed incrementally without blocking the async executor; query results are collected in memory. Plans that scan the input more than once are unsupported.