pub fn deserialize_batch<F>(
rows: &[ByteRecord],
fields: &[Field],
projection: Option<&[usize]>,
line_number: usize,
deserialize_column: F
) -> Result<Chunk<Arc<dyn Array>>> where
F: Fn(&[ByteRecord], usize, DataType, usize) -> Result<Arc<dyn Array>>,
Available on (crate features
io_csv_read
or io_csv_read_async
or io_csv_write
) and crate feature io_csv_read
only.Expand description
Deserializes rows ByteRecord
into a Chunk
.
Note that this is a convenience function: column deserialization
is trivially parallelizable (e.g. rayon).