Skip to main content

flush_batch_physical_tracked

servers::batcher::logical_table::batch

Function flush_batch_physical_tracked 

Source 
async fn flush_batch_physical_tracked(
    table_batches: &[TableBatch],
    physical_table_name: &str,
    ctx: &QueryContextRef,
    partition_manager: &(impl PhysicalFlushPartitionProvider + ?Sized),
    write_dispatcher: &(impl PhysicalFlushWriteDispatcher + ?Sized),
    catalog_manager: &(impl PhysicalFlushCatalogProvider + ?Sized),
    inputs: usize,
) -> Result<Vec<WriteProgress>>