Skip to main content

parallel_scan_stream

reddb::storage::query::executors::parallel_scan

Function parallel_scan_stream 

Source 
pub fn parallel_scan_stream<T, U, F>(
    input: &[T],
    batch_rows: usize,
    worker: F,
) -> ScanBatches<'_, T, U, F> ⓘ
where
    F: Fn(&[T]) -> Vec<U>,
Expand description

Construct a pull-based ScanBatches over input, applying worker to each batch_rows-sized slice on demand. A batch_rows of 0 is clamped to 1 so the iterator always makes progress.