Skip to main content

spawn_flush

servers::pending_rows_batcher

Function spawn_flush 

Source 
async fn spawn_flush(
    flush: FlushBatch,
    partition_manager: PartitionRuleManagerRef,
    node_manager: NodeManagerRef,
    catalog_manager: CatalogManagerRef,
    semaphore: Arc<Semaphore>,
)