Skip to main content

write_tables

operator::statement::export_logical_tables

Function write_tables 

Source 
async fn write_tables(
    unit: &LogicalTableExport,
    stream: SendableRecordBatchStream,
    store: &ObjectStore,
    limits: LogicalTableExportLimits,
    cancellation: &CancellationToken,
    active: &mut Option<ActiveWriter>,
) -> Result<LogicalTableExportSummary>