Module rs_query

Expand description

SQL query execution via Apache DataFusion.

Structs§

ChannelPartitionStream 🔒: A channel-backed partition is single-execution because receiving consumes its input. Plans that scan it more than once return an execution error.

async_record_batch_channel: Creates a bounded, executor-friendly input channel for async SQL queries.
collect_with_empty_batch 🔒
execute_sql: Synchronously executes SQL against in-memory Arrow batches.
execute_sql_and_write_from_input_async 🔒
execute_sql_and_write_stream: Synchronously streams SQL output directly to a configured writer.
execute_sql_and_write_stream_async: Asynchronously writes each SQL output batch as soon as DataFusion produces it. Plans that scan the channel-backed table more than once are unsupported.
execute_sql_async: Executes SQL asynchronously against in-memory Arrow batches.
execute_sql_from_input_async 🔒
execute_sql_stream: Synchronously executes SQL from a single-use channel of Arrow batches.
execute_sql_stream_async: Asynchronously executes SQL from a single-use channel of Arrow batches.
read_sql_file: Reads and validates a SQL query file.
record_batch_channel: Creates a bounded input channel for streaming SQL queries.
runtime 🔒
streaming_context 🔒

AsyncRecordBatchReceiver: Async receiving half of a streaming SQL input channel.
AsyncRecordBatchSender: Async sending half of a streaming SQL input channel.
RecordBatchReceiver: Error-aware Arrow batch receiver used by streaming SQL queries.
RecordBatchSender: Sending half of a streaming SQL input channel.