Skip to main content

execute_sql_stream

Function execute_sql_stream 

Source
pub fn execute_sql_stream(
    receiver: RecordBatchReceiver,
    schema: SchemaRef,
    table_name: &str,
    sql: &str,
) -> Result<Vec<RecordBatch>, ReadStatError>
Expand description

Synchronously executes SQL from a single-use channel of Arrow batches.

Input is consumed incrementally; query results are collected in memory.