Struct differential_dataflow::trace::wrappers::freeze::TraceFreeze

pub struct TraceFreeze<Tr, F> where
    Tr: TraceReader,
    Tr::Time: Lattice + Clone + 'static,
    F: Fn(&Tr::Time) -> Option<Tr::Time>,  { /* fields omitted */ }

Wrapper to provide trace to nested scope.

Implementations

impl<Tr, F> TraceFreeze<Tr, F> where
    Tr: TraceReader,
    Tr::Batch: Clone,
    Tr::Key: 'static,
    Tr::Val: 'static,
    Tr::Time: Lattice + Clone + 'static,
    Tr::R: 'static,
    F: Fn(&Tr::Time) -> Option<Tr::Time>, 

pub fn make_from(trace: Tr, func: Rc<F>) -> Self

Makes a new trace wrapper

Trait Implementations

impl<Tr, F> Clone for TraceFreeze<Tr, F> where
    Tr: TraceReader + Clone,
    Tr::Time: Lattice + Clone + 'static,
    F: Fn(&Tr::Time) -> Option<Tr::Time>, 

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Tr, F> TraceReader for TraceFreeze<Tr, F> where
    Tr: TraceReader,
    Tr::Batch: Clone,
    Tr::Key: 'static,
    Tr::Val: 'static,
    Tr::Time: Lattice + Clone + 'static,
    Tr::R: 'static,
    F: Fn(&Tr::Time) -> Option<Tr::Time> + 'static, 

type Key = Tr::Key

Key by which updates are indexed.

type Val = Tr::Val

Values associated with keys.

type Time = Tr::Time

Timestamps associated with updates

type R = Tr::R

Associated update.

type Batch = BatchFreeze<Tr::Key, Tr::Val, Tr::Time, Tr::R, Tr::Batch, F>

The type of an immutable collection of updates.

type Cursor = CursorFreeze<Tr::Key, Tr::Val, Tr::Time, Tr::R, Tr::Cursor, F>

The type used to enumerate the collections contents.

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

Maps logic across the non-empty sequence of batches in the trace.

fn set_logical_compaction(&mut self, frontier: AntichainRef<'_, Tr::Time>)

Advances the frontier that constrains logical compaction.

fn get_logical_compaction(&mut self) -> AntichainRef<'_, Tr::Time>

Reports the logical compaction frontier.

fn set_physical_compaction(&mut self, frontier: AntichainRef<'_, Tr::Time>)

Advances the frontier that constrains physical compaction.

fn get_physical_compaction(&mut self) -> AntichainRef<'_, Tr::Time>

Reports the physical compaction frontier.

fn cursor_through(
    &mut self,
    upper: AntichainRef<'_, Tr::Time>
) -> Option<(Self::Cursor, <Self::Cursor as Cursor<Tr::Key, Tr::Val, Tr::Time, Tr::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<Self::Key, Self::Val, Self::Time, Self::R>>::Storage)

Provides a cursor over updates contained in the trace.

fn advance_by(&mut self, frontier: AntichainRef<'_, Self::Time>)

👎 Deprecated since 0.11:

please use set_logical_compaction

Deprecated form of set_logical_compaction.

fn advance_frontier(&mut self) -> AntichainRef<'_, Self::Time>

👎 Deprecated since 0.11:

please use get_logical_compaction

Deprecated form of get_logical_compaction.

fn distinguish_since(&mut self, frontier: AntichainRef<'_, Self::Time>)

👎 Deprecated since 0.11:

please use set_physical_compaction

Deprecated form of set_physical_compaction.

fn distinguish_frontier(&mut self) -> AntichainRef<'_, Self::Time>

👎 Deprecated since 0.11:

please use get_physical_compaction

Deprecated form of get_physical_compaction.

fn read_upper(&mut self, target: &mut Antichain<Self::Time>) where
    Self::Time: Timestamp, 

Reads the upper frontier of committed times.

fn advance_upper(&mut self, upper: &mut Antichain<Self::Time>) where
    Self::Time: Timestamp, 

Advances upper by any empty batches.