Trait PartitionedStream

Source

pub trait PartitionedStream: Debug + Send {
    type Output;

    // Required methods
    fn partitions(&self) -> usize;
    fn poll_next(
        &mut self,
        cx: &mut Context<'_>,
        stream_idx: usize,
    ) -> Poll<Option<Self::Output>>;
}

Expand description

A Stream that has multiple partitions that can be polled separately but not concurrently

Used by sort preserving merge to decouple the cursor merging logic from the source of the cursors, the intention being to allow preserving any row encoding performed for intermediate sorts