spawn_column_parallel_row_group_writer

datafusion_datasource_parquet::file_format

Function spawn_column_parallel_row_group_writer 

Source 
fn spawn_column_parallel_row_group_writer(
    col_writers: Vec<ArrowColumnWriter>,
    max_buffer_size: usize,
    pool: &Arc<dyn MemoryPool>,
) -> Result<(Vec<SpawnedTask<Result<(ArrowColumnWriter, MemoryReservation)>>>, Vec<Sender<ArrowLeafColumn>>)>
Expand description

Spawns a parallel serialization task for each column Returns join handles for each columns serialization task along with a send channel to send arrow arrays to each serialization task.