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.