Skip to main content

spawn_flush

Function spawn_flush 

Source
pub(crate) async fn spawn_flush(
    flush: Batch,
    partition_manager: PartitionRuleManagerRef,
    write_dispatcher: WriteDispatcherRef,
    catalog_manager: CatalogManagerRef,
    flow_notification_tx: FlowNotifier,
    flush_limiter: FlushLimiter,
)
Expand description

Spawns a physical flush with the configured concurrency limit.