Skip to main content

export_stream

operator::statement::export_logical_tables

Function export_stream 

Source 
async fn export_stream(
    unit: &LogicalTableExport,
    stream: SendableRecordBatchStream,
    store: &ObjectStore,
    limits: LogicalTableExportLimits,
    cancellation: &CancellationToken,
) -> Result<LogicalTableExportSummary>