Skip to main content

flush_batch_with_managers

servers::pending_rows_batcher

Function flush_batch_with_managers 

Source 
async fn flush_batch_with_managers(
    flush: FlushBatch,
    partition_manager: PartitionRuleManagerRef,
    node_manager: NodeManagerRef,
    catalog_manager: CatalogManagerRef,
    flow_notification_tx: Sender<FlowNotification>,
)