Skip to main content

execute_sql_and_write_stream_async

Function execute_sql_and_write_stream_async 

Source
pub async fn execute_sql_and_write_stream_async(
    receiver: AsyncRecordBatchReceiver,
    schema: SchemaRef,
    table_name: &str,
    sql: &str,
    config: &WriteConfig,
) -> Result<usize, ReadStatError>
Expand description

Asynchronously writes each SQL output batch as soon as DataFusion produces it. Plans that scan the channel-backed table more than once are unsupported.