flatten_watermarked_buckets

Function flatten_watermarked_buckets 

Source
pub fn flatten_watermarked_buckets<S>(
    stream: S,
    range: Range<u64>,
    bucket_size: u64,
    direction: ScanDirection,
) -> impl Stream<Item = BitmapScanResult<Watermarked<u64>>> + Send + 'static
where S: Stream<Item = BitmapScanResult<Watermarked<(u64, RoaringBitmap)>>> + Send + 'static,
Expand description

Flatten marked bucket bitmaps into absolute member ids with edge-bucket trimming against range. Watermarks pass through unchanged.