Struct BatchFrontier 

pub struct BatchFrontier<B, T> { /* private fields */ }

Wrapper to restrict a batch’s times to a frontier range.

Implementations

impl<B, T> BatchFrontier<B, T>

pub fn make_from( batch: B, since: AntichainRef<'_, T>, until: AntichainRef<'_, T>, ) -> Self

where T: Clone,

Makes a new wrapper

pub fn inner(&self) -> &B

The wrapped batch, whose times are neither advanced nor suppressed.

Its times must be presented through BatchFrontier::advance_time, which is the whole of the wrapper’s read-side semantics.

pub fn advance_time(&self, time: &mut T) -> bool

where T: Lattice + Timestamp,

Applies the wrapper’s time semantics to a time of the wrapped batch.

The time is advanced by since, which accumulates the updates at or before since rather than presenting them partially accumulated. The method returns whether the advanced time should be presented at all: times at or after until are suppressed, even when they are part of a batch that spans until.

Trait Implementations

impl<B: Clone, T: Clone> Clone for BatchFrontier<B, T>

fn clone(&self) -> BatchFrontier<B, T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<B> Navigable for BatchFrontier<B, <B::Cursor as Cursor>::Time>

where B: Navigable,

type Cursor = BatchCursorFrontier<<B as Navigable>::Cursor>

The cursor type.

fn cursor(&self) -> Self::Cursor

Acquire a cursor suitable for the instance.