Skip to main content

execute_sql_stream_async

Function execute_sql_stream_async 

Source
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.