Skip to main content

flush_batch

servers::pending_rows_batcher

Function flush_batch 

Source 
async fn flush_batch(
    flush: FlushBatch,
    partition_manager: PartitionRuleManagerRef,
    node_manager: NodeManagerRef,
    catalog_manager: CatalogManagerRef,
)