Trait differential_dataflow::trace::BatchReader
source · pub trait BatchReaderwhere
Self: Sized,{
type Key<'a>: Copy + Clone + Ord;
type Val<'a>: Copy + Clone;
type Time: Timestamp + Lattice + Ord + Clone;
type TimeGat<'a>: Copy + IntoOwned<'a, Owned = Self::Time>;
type Diff: Semigroup + 'static;
type DiffGat<'a>: Copy + IntoOwned<'a, Owned = Self::Diff>;
type Cursor: for<'a> Cursor<Storage = Self, Key<'a> = Self::Key<'a>, Val<'a> = Self::Val<'a>, Time = Self::Time, TimeGat<'a> = Self::TimeGat<'a>, Diff = Self::Diff, DiffGat<'a> = Self::DiffGat<'a>>;
// Required methods
fn cursor(&self) -> Self::Cursor;
fn len(&self) -> usize;
fn description(&self) -> &Description<Self::Time>;
// Provided methods
fn is_empty(&self) -> bool { ... }
fn lower(&self) -> &Antichain<Self::Time> { ... }
fn upper(&self) -> &Antichain<Self::Time> { ... }
}Expand description
A batch of updates whose contents may be read.
This is a restricted interface to batches of updates, which support the reading of the batch’s contents, but do not expose ways to construct the batches. This trait is appropriate for views of the batch, and is especially useful for views derived from other sources in ways that prevent the construction of batches from the type of data in the view (for example, filtered views, or views with extended time coordinates).
Required Associated Types§
Required Methods§
sourcefn description(&self) -> &Description<Self::Time>
fn description(&self) -> &Description<Self::Time>
Describes the times of the updates in the batch.
Provided Methods§
Object Safety§
This trait is not object safe.
Implementations on Foreign Types§
source§impl<B: BatchReader> BatchReader for Rc<B>
impl<B: BatchReader> BatchReader for Rc<B>
§type Cursor = RcBatchCursor<<B as BatchReader>::Cursor>
type Cursor = RcBatchCursor<<B as BatchReader>::Cursor>
The type used to enumerate the batch’s contents.
source§fn description(&self) -> &Description<Self::Time>
fn description(&self) -> &Description<Self::Time>
Describes the times of the updates in the batch.