Struct KWayMergeFeed 

pub struct KWayMergeFeed<F>
where
    F: FallibleBatchFeed,
{ /* private fields */ }

Streaming deterministic merge over multiple fallible timestamp batch feeds.

Implementations

impl<F> KWayMergeFeed<F>

where F: FallibleBatchFeed,

pub fn new(feeds: Vec<F>) -> Self

Create a merge using input position as series_rank.

pub fn series_count(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn next_timestamp_batch( &mut self, ) -> Result<Option<TimestampBatch>, KWayMergeError<F::Error>>

Return the next complete merged timestamp batch.

Trait Implementations

impl<F> FallibleBatchFeed for KWayMergeFeed<F>

where F: FallibleBatchFeed,

type Error = KWayMergeError<<F as FallibleBatchFeed>::Error>

fn next_batch(&mut self) -> Result<Option<TimestampBatch>, Self::Error>

Return every event at the next timestamp, or None at end of input.