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 is_empty(&self) -> bool { ... }
    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.

Loading content...

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.

Loading content...

Provided methods

fn is_empty(&self) -> bool

True if the batch is empty.

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.

Loading content...

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.

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.

Loading content...

Implementors

impl<K, T, R, O> BatchReader<K, (), T, R> for OrdKeyBatch<K, T, R, O> where
    K: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + 'static,
    R: Semigroup,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug, 

type Cursor = OrdKeyCursor<T, R, O>

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

fn len(&self) -> usize

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

impl<K, V, T, R, B> BatchReader<K, V, T, R> for BatchFrontier<K, V, T, R, B> where
    B: BatchReader<K, V, T, R>,
    T: Timestamp + Lattice, 

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

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

fn len(&self) -> usize

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

impl<K, V, T, R, B, F> BatchReader<K, V, T, R> for BatchFilter<K, V, T, R, B, F> where
    B: BatchReader<K, V, T, R>,
    T: Timestamp,
    F: FnMut(&K, &V) -> bool + Clone + 'static, 

type Cursor = BatchCursorFilter<K, V, T, R, B, F>

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

fn len(&self) -> usize

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

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>

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

fn len(&self) -> usize

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

impl<K, V, T, R, B, TInner> BatchReader<K, V, TInner, R> for differential_dataflow::trace::wrappers::enter::BatchEnter<K, V, T, R, B, TInner> where
    B: BatchReader<K, V, T, R>,
    T: Timestamp,
    TInner: Refines<T> + Lattice, 

type Cursor = BatchCursorEnter<K, V, T, R, B, TInner>

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

fn len(&self) -> usize

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

impl<K, V, T, R, B, TInner, F> BatchReader<K, V, TInner, R> for differential_dataflow::trace::wrappers::enter_at::BatchEnter<K, V, T, R, B, TInner, F> where
    B: BatchReader<K, V, T, R>,
    T: Timestamp,
    TInner: Refines<T> + Lattice,
    F: FnMut(&K, &V, &T) -> TInner + Clone, 

type Cursor = BatchCursorEnter<K, V, T, R, B, TInner, F>

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

fn len(&self) -> usize

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

impl<K, V, T, R, O> BatchReader<K, V, T, R> for OrdValBatch<K, V, T, R, O> where
    K: Ord + Clone + 'static,
    V: Ord + Clone + 'static,
    T: Lattice + Ord + Clone + 'static,
    R: Semigroup,
    O: OrdOffset,
    <O as TryFrom<usize>>::Error: Debug,
    <O as TryInto<usize>>::Error: Debug, 

type Cursor = OrdValCursor<V, T, R, O>

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

fn len(&self) -> usize

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

Loading content...