Skip to main content

spawn_flush

servers::batcher::logical_table::batch

Function spawn_flush 

Source 
pub(super) async fn spawn_flush(
    flush: Batch,
    partition_manager: PartitionRuleManagerRef,
    node_manager: NodeManagerRef,
    catalog_manager: CatalogManagerRef,
    flow_notification_tx: FlowNotifier,
    flush_limiter: FlushLimiter,
)