column_serializer_task

datafusion_datasource_parquet::file_format

Function column_serializer_task 

Source 
async fn column_serializer_task(
    rx: Receiver<ArrowLeafColumn>,
    writer: ArrowColumnWriter,
    reservation: MemoryReservation,
) -> Result<(ArrowColumnWriter, MemoryReservation)>
Expand description

Consumes a stream of [ArrowLeafColumn] via a channel and serializes them using an [ArrowColumnWriter] Once the channel is exhausted, returns the ArrowColumnWriter.