Skip to main content

flatten_watermarked_buckets

sui_inverted_index::bitmap_query

Function flatten_watermarked_buckets 

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

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