Function dbcrossbarlib::rechunk::rechunk_csvs
source · pub fn rechunk_csvs(
ctx: Context,
chunk_size: usize,
streams: BoxStream<CsvStream>
) -> Result<BoxStream<CsvStream>>
Expand description
Given a stream of streams CSV data, return another stream of CSV streams
where the CSV data is approximately chunk_size
long whenever possible.