Function dbcrossbarlib::rechunk::rechunk_csvs[][src]

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.