Struct differential_dataflow::trace::wrappers::rc::TraceRc

pub struct TraceRc<Tr> where
    Tr::Time: Lattice + Ord + Clone + 'static,
    Tr: TraceReader,  {
    pub wrapper: Rc<RefCell<TraceBox<Tr>>>,
    // some fields omitted
}

A handle to a shared trace.

As long as the handle exists, the wrapped trace should continue to exist and will not advance its timestamps past the frontier maintained by the handle. The intent is that such a handle appears as if it is a privately maintained trace, despite being backed by shared resources.

Fields

wrapper: Rc<RefCell<TraceBox<Tr>>>

Wrapped trace. Please be gentle when using.

Implementations

impl<Tr> TraceRc<Tr> where
    Tr::Time: Lattice + Ord + Clone + 'static,
    Tr: TraceReader, 

pub fn make_from(trace: Tr) -> (Self, Rc<RefCell<TraceBox<Tr>>>)

Allocates a new handle from an existing wrapped wrapper.

Trait Implementations

impl<Tr> Clone for TraceRc<Tr> where
    Tr::Time: Lattice + Ord + Clone,
    Tr: TraceReader, 

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> Drop for TraceRc<Tr> where
    Tr::Time: Lattice + Ord + Clone + 'static,
    Tr: TraceReader, 

fn drop(&mut self)

Executes the destructor for this type.

impl<Tr> TraceReader for TraceRc<Tr> where
    Tr::Time: Lattice + Ord + Clone + 'static,
    Tr: TraceReader, 

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 = Tr::Batch

The type of an immutable collection of updates.

type Cursor = Tr::Cursor

The type used to enumerate the collections contents.

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

Sets frontier to now be elements in frontier.

This change may not have immediately observable effects. It informs the shared trace that this handle no longer requires access to times other than those in the future of frontier, but if there are other handles to the same trace, it may not yet be able to compact.

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

Reports the logical compaction frontier.

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

Allows the trace to compact batches of times before frontier.

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

Reports the physical compaction frontier.

fn cursor_through(
    &mut self,
    frontier: AntichainRef<'_, Tr::Time>
) -> Option<(Tr::Cursor, <Tr::Cursor as Cursor<Tr::Key, Tr::Val, Tr::Time, Tr::R>>::Storage)>

Creates a new cursor over the wrapped trace.

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

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

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.