mz_compute::typedefs

Type Alias ErrEnter

Source
pub type ErrEnter<T, TEnter> = TraceEnter<TraceFrontier<TraceAgent<Spine<Rc<OrdKeyBatch<MzStack<((DataflowError, ()), T, Diff)>>>>>>, TEnter>;

Aliased Type§

struct ErrEnter<T, TEnter> { /* private fields */ }

Implementations

Source§

impl<Tr, TInner> TraceEnter<Tr, TInner>
where Tr: TraceReader, TInner: Refines<<Tr as TraceReader>::Time> + Lattice,

Source

pub fn make_from(trace: Tr) -> TraceEnter<Tr, TInner>

Makes a new trace wrapper

Trait Implementations

Source§

impl<Tr, TInner> Clone for TraceEnter<Tr, TInner>
where Tr: TraceReader + Clone,

Source§

fn clone(&self) -> TraceEnter<Tr, TInner>

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, TInner> TraceReader for TraceEnter<Tr, TInner>
where Tr: TraceReader, <Tr as TraceReader>::Batch: Clone, TInner: Refines<<Tr as TraceReader>::Time> + Lattice,

Source§

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

Key by which updates are indexed.
Source§

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

Values associated with keys.
Source§

type Time = TInner

Timestamps associated with updates
Source§

type TimeGat<'a> = &'a TInner

Borrowed form of timestamp.
Source§

type Diff = <Tr as TraceReader>::Diff

Owned form of update difference.
Source§

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

Borrowed form of update difference.
Source§

type Batch = BatchEnter<<Tr as TraceReader>::Batch, TInner>

The type of an immutable collection of updates.
Source§

type Storage = <Tr as TraceReader>::Storage

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

type Cursor = CursorEnter<<Tr as TraceReader>::Cursor, TInner>

The type used to enumerate the collections contents.
Source§

fn map_batches<F>(&self, f: F)
where F: FnMut(&<TraceEnter<Tr, TInner> as TraceReader>::Batch),

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

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

Advances the frontier that constrains logical compaction. Read more
Source§

fn get_logical_compaction(&mut self) -> AntichainRef<'_, TInner>

Reports the logical compaction frontier. Read more
Source§

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

Advances the frontier that constrains physical compaction. Read more
Source§

fn get_physical_compaction(&mut self) -> AntichainRef<'_, TInner>

Reports the physical compaction frontier. Read more
Source§

fn cursor_through( &mut self, upper: AntichainRef<'_, TInner>, ) -> Option<(<TraceEnter<Tr, TInner> as TraceReader>::Cursor, <TraceEnter<Tr, TInner> as TraceReader>::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. 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