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

source ·
pub struct TraceRc<Tr: TraceReader> {
    pub wrapper: Rc<RefCell<TraceBox<Tr>>>,
    /* private fields */
}
Expand description

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§

source§

impl<Tr: TraceReader> TraceRc<Tr>

source

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

Allocates a new handle from an existing wrapped wrapper.

Trait Implementations§

source§

impl<Tr: TraceReader> Clone for TraceRc<Tr>

source§

fn clone(&self) -> Self

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl<Tr: TraceReader> Drop for TraceRc<Tr>

source§

fn drop(&mut self)

Executes the destructor for this type. Read more
source§

impl<Tr: TraceReader> TraceReader for TraceRc<Tr>

source§

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.

source§

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

Allows the trace to compact batches of times before frontier.

source§

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

Creates a new cursor over the wrapped trace.

§

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 Time = <Tr as TraceReader>::Time

Timestamps associated with updates
§

type Diff = <Tr as TraceReader>::Diff

Associated update.
§

type Batch = <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 = <Tr as TraceReader>::Cursor

The type used to enumerate the collections contents.
source§

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

Reports the logical compaction frontier. Read more
source§

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

Reports the physical compaction frontier. Read more
source§

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

Maps logic across the non-empty sequence of batches in the trace. Read more
source§

fn cursor(&mut self) -> (Self::Cursor, Self::Storage)

Provides a cursor over updates contained in the trace.
source§

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

👎Deprecated since 0.11: please use set_logical_compaction
Deprecated form of set_logical_compaction.
source§

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

👎Deprecated since 0.11: please use get_logical_compaction
Deprecated form of get_logical_compaction.
source§

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

👎Deprecated since 0.11: please use set_physical_compaction
Deprecated form of set_physical_compaction.
source§

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

👎Deprecated since 0.11: please use get_physical_compaction
Deprecated form of get_physical_compaction.
source§

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

Reads the upper frontier of committed times.
source§

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

Advances upper by any empty batches. Read more

Auto Trait Implementations§

§

impl<Tr> Freeze for TraceRc<Tr>

§

impl<Tr> !RefUnwindSafe for TraceRc<Tr>

§

impl<Tr> !Send for TraceRc<Tr>

§

impl<Tr> !Sync for TraceRc<Tr>

§

impl<Tr> Unpin for TraceRc<Tr>
where <Tr as TraceReader>::Time: Unpin,

§

impl<Tr> !UnwindSafe for TraceRc<Tr>

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
where R: Region<Index = (usize, usize)>, O: OffsetContainer<usize>, T: CopyOnto<R>,

source§

fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index

Copy self into the target container, returning an index that allows to look up the corresponding read item.
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<R, T> PushInto<FlatStack<R>> for T
where R: Region + Clone + 'static, T: CopyOnto<R>,

source§

fn push_into(self, target: &mut FlatStack<R>)

Push self into the target container.
source§

impl<T> PushInto<Vec<T>> for T

source§

fn push_into(self, target: &mut Vec<T>)

Push self into the target container.
source§

impl<T> ToOwned for T
where T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<T> Data for T
where T: Clone + 'static,