Struct differential_dataflow::trace::wrappers::enter::TraceEnter

pub struct TraceEnter<K, V, T, R, Tr, TInner> { /* private fields */ }

Wrapper to provide trace to nested scope.

Implementations

impl<K, V, T, R, Tr, TInner> TraceEnter<K, V, T, R, Tr, TInner>where
    Tr: TraceReader<K, V, T, R>,
    T: Timestamp,
    TInner: Refines<T> + Lattice,

pub fn make_from(trace: Tr) -> Self

Makes a new trace wrapper

Trait Implementations

impl<K, V, T, R, Tr, TInner> Clone for TraceEnter<K, V, T, R, Tr, TInner>where
    Tr: TraceReader<K, V, T, R> + Clone,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<K, V, T, R, Tr, TInner> TraceReader<K, V, TInner, R> for TraceEnter<K, V, T, R, Tr, TInner>where
    Tr: TraceReader<K, V, T, R>,
    Tr::Batch: Clone,
    K: 'static,
    V: 'static,
    T: Timestamp,
    TInner: Refines<T> + Lattice,
    R: 'static,

type Batch = BatchEnter<K, V, T, R, <Tr as TraceReader<K, V, T, R>>::Batch, TInner>

The type of an immutable collection of updates.

type Cursor = CursorEnter<K, V, T, R, <Tr as TraceReader<K, V, T, R>>::Cursor, TInner>

The type used to enumerate the collections contents.

fn map_batches<F: FnMut(&Self::Batch)>(&mut self, f: F)

Maps some logic across the batches the collection manages.

fn advance_by(&mut self, frontier: &[TInner])

Advances the frontier of times the collection must be correctly accumulable through.

fn advance_frontier(&mut self) -> &[TInner]

Reports the frontier from which all time comparisions should be accurate.

fn distinguish_since(&mut self, frontier: &[TInner])

Advances the frontier that may be used in cursor_through.

fn distinguish_frontier(&mut self) -> &[TInner]

Reports the frontier from which the collection may be subsetted.

fn cursor_through(
    &mut self,
    upper: &[TInner]
) -> Option<(Self::Cursor, <Self::Cursor as Cursor<K, V, TInner, R>>::Storage)>

Acquires a cursor to the restriction of the collection’s contents to updates at times not greater or equal to an element of upper.

fn cursor(
    &mut self
) -> (Self::Cursor, <Self::Cursor as Cursor<Key, Val, Time, R>>::Storage)

Provides a cursor over updates contained in the trace.