Struct differential_dataflow::trace::wrappers::frontier::TraceFrontier

pub struct TraceFrontier<Tr: TraceReader> { /* private fields */ }

Wrapper to provide trace to nested scope.

Implementations

impl<Tr: TraceReader> TraceFrontier<Tr>

pub fn make_from( trace: Tr, since: AntichainRef<'_, Tr::Time>, until: AntichainRef<'_, Tr::Time> ) -> Self

Makes a new trace wrapper

Trait Implementations

impl<Tr: TraceReader + Clone> Clone for TraceFrontier<Tr>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Tr: TraceReader> TraceReader for TraceFrontier<Tr>

type Key<'a> = <Tr as TraceReader>::Key<'a>

Key by which updates are indexed.

type KeyOwned = <Tr as TraceReader>::KeyOwned

Owned version of the above.

type Val<'a> = <Tr as TraceReader>::Val<'a>

Values associated with keys.

type ValOwned = <Tr as TraceReader>::ValOwned

Owned version of the above.

type Time = <Tr as TraceReader>::Time

Timestamps associated with updates

type Diff = <Tr as TraceReader>::Diff

Associated update.

type Batch = BatchFrontier<<Tr as TraceReader>::Batch>

The type of an immutable collection of updates.

type Storage = <Tr as TraceReader>::Storage

Storage type for Self::Cursor. Likely related to Self::Batch.

type Cursor = CursorFrontier<<Tr as TraceReader>::Cursor, <Tr as TraceReader>::Time>

The type used to enumerate the collections contents.

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

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

Reads the upper frontier of committed times.

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

Advances upper by any empty batches.