Trait differential_dataflow::trace::BatchReader

pub trait BatchReader<K, V, T, R> where
    Self: Sized, {
    type Cursor: Cursor<K, V, T, R, Storage = Self>;
    fn cursor(&self) -> Self::Cursor;
    fn len(&self) -> usize;
    fn description(&self) -> &Description<T>;

    fn lower(&self) -> &[T] { ... }
    fn upper(&self) -> &[T] { ... }
}

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).

Associated Types

type Cursor: Cursor<K, V, T, R, Storage = Self>

The type used to enumerate the batch's contents.

Required Methods

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

Acquires a cursor to the batch's contents.

fn len(&self) -> usize

The number of updates in the batch.

fn description(&self) -> &Description<T>

Describes the times of the updates in the batch.

Provided Methods

fn lower(&self) -> &[T]

All times in the batch are greater or equal to an element of lower.

fn upper(&self) -> &[T]

All times in the batch are not greater or equal to any element of upper.

Implementations on Foreign Types

impl<K, V, T, R, B: BatchReader<K, V, T, R>> BatchReader<K, V, T, R> for Rc<B>

type Cursor = RcBatchCursor<K, V, T, R, B>

The type used to enumerate the batch's contents.

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

Acquires a cursor to the batch's contents.

fn len(&self) -> usize

The number of updates in the batch.

fn description(&self) -> &Description<T>

Describes the times of the updates in the batch.

fn lower(&self) -> &[T]

fn upper(&self) -> &[T]

impl<K, V, T, R, B: BatchReader<K, V, T, R> + Abomonation> BatchReader<K, V, T, R> for Abomonated<B, Vec<u8>>

type Cursor = AbomonatedBatchCursor<K, V, T, R, B>

The type used to enumerate the batch's contents.

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

Acquires a cursor to the batch's contents.

fn len(&self) -> usize

The number of updates in the batch.

fn description(&self) -> &Description<T>

Describes the times of the updates in the batch.

fn lower(&self) -> &[T]

fn upper(&self) -> &[T]

Implementors

• impl<K, V, T, R> BatchReader<K, V, T, R> for OrdValBatch<K, V, T, R> where
    K: Ord + Clone + 'static,
    V: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + 'static,
    R: Diff,  type Cursor = OrdValCursor<V, T, R>;
• impl<K, T, R> BatchReader<K, (), T, R> for OrdKeyBatch<K, T, R> where
    K: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + 'static,
    R: Diff,  type Cursor = OrdKeyCursor<T, R>;
• impl<K, V, T, R, B, TInner> BatchReader<K, V, Product<T, TInner>, R> for BatchEnter<K, V, T, R, B, TInner> where
    B: BatchReader<K, V, T, R>,
    T: Clone + Default,
    TInner: Clone + Default,  type Cursor = BatchCursorEnter<K, V, T, R, B, TInner>;
• impl<K, V, T, R, B, F> BatchReader<K, V, T, R> for BatchFreeze<K, V, T, R, B, F> where
    B: BatchReader<K, V, T, R>,
    T: Clone + Default,
    F: Fn(&T) -> Option<T>,  type Cursor = BatchCursorFreeze<K, V, T, R, B, F>;