Skip to main content

export_stream_managed

operator::statement::export_logical_tables

Function export_stream_managed 

Source 
async fn export_stream_managed(
    unit: &LogicalTableExport,
    stream: SendableRecordBatchStream,
    store: &ObjectStore,
    limits: LogicalTableExportLimits,
    cancellation: &CancellationToken,
    budget: Arc<ExportWriteBudget>,
    packed: Option<PackedWriterRef>,
) -> Result<LogicalTableExportSummary>