Struct differential_dataflow::trace::wrappers::rc::TraceBox

pub struct TraceBox<Tr: TraceReader> {
    pub logical_compaction: MutableAntichain<Tr::Time>,
    pub physical_compaction: MutableAntichain<Tr::Time>,
    pub trace: Tr,
}

A wrapper around a trace which tracks the frontiers of all referees.

This is an internal type, unlikely to be useful to higher-level programs, but exposed just in case. This type is equivalent to a RefCell, in that it wraps the mutable state that multiple referrers may influence.

Fields

logical_compaction: MutableAntichain<Tr::Time>

accumulated holds on times for advancement.

physical_compaction: MutableAntichain<Tr::Time>

accumulated holds on times for distinction.

trace: Tr

The wrapped trace.

Implementations

impl<Tr: TraceReader> TraceBox<Tr>

pub fn new(trace: Tr) -> Self

Moves an existing trace into a shareable trace wrapper.

The trace may already exist and have non-initial advance and distinguish frontiers. The boxing process will fish these out and make sure that they are used for the initial read capabilities.

pub fn adjust_logical_compaction( &mut self, lower: AntichainRef<'_, Tr::Time>, upper: AntichainRef<'_, Tr::Time>, )

Replaces elements of lower with those of upper.

pub fn adjust_physical_compaction( &mut self, lower: AntichainRef<'_, Tr::Time>, upper: AntichainRef<'_, Tr::Time>, )

Replaces elements of lower with those of upper.