spawn_rg_join_and_finalize_task

datafusion_datasource_parquet::file_format

Function spawn_rg_join_and_finalize_task 

Source 
fn spawn_rg_join_and_finalize_task(
    column_writer_tasks: Vec<SpawnedTask<Result<(ArrowColumnWriter, MemoryReservation)>>>,
    rg_rows: usize,
    pool: &Arc<dyn MemoryPool>,
) -> SpawnedTask<Result<(Vec<ArrowColumnChunk>, MemoryReservation, usize)>> ⓘ
Expand description

Spawns a tokio task which joins the parallel column writer tasks, and finalizes the row group