Skip to main content

parallel_scan_rows

reddb_server::storage::query::executors::parallel_scan

Function parallel_scan_rows 

Source 
pub fn parallel_scan_rows<'a, T, U, F>(
    input: &'a [T],
    batch_rows: usize,
    worker: F,
) -> impl Iterator<Item = U> + 'a
where
    T: 'a,
    U: 'a,
    F: Fn(&[T]) -> Vec<U> + 'a,
Expand description

Per-row flattening helper over parallel_scan_stream. Yields one U at a time — the natural shape for a record-at-a-time streaming driver — while keeping the same lazy, bounded-memory pull semantics (at most one batch is materialised at a time).