Skip to main content

flush_batch

Function flush_batch 

Source
pub(crate) async fn flush_batch(
    flush: Batch,
    partition_manager: &(impl PhysicalFlushPartitionProvider + ?Sized),
    write_dispatcher: &(impl PhysicalFlushWriteDispatcher + ?Sized),
    catalog_manager: &(impl PhysicalFlushCatalogProvider + ?Sized),
    flow_notification_tx: FlowNotifier,
)
Expand description

Flushes a batch and reports completion to its waiters.