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>
impl<Tr, TInner> TraceEnter<Tr, TInner>
Sourcepub fn make_from(trace: Tr) -> TraceEnter<Tr, TInner>
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,
impl<Tr, TInner> Clone for TraceEnter<Tr, TInner>where
Tr: TraceReader + Clone,
Source§fn clone(&self) -> TraceEnter<Tr, TInner>
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)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl<Tr, TInner> TraceReader for TraceEnter<Tr, TInner>where
Tr: TraceReader,
<Tr as TraceReader>::Batch: Clone,
TInner: Refines<<Tr as TraceReader>::Time> + Lattice,
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>
type Key<'a> = <Tr as TraceReader>::Key<'a>
Key by which updates are indexed.
Source§type Val<'a> = <Tr as TraceReader>::Val<'a>
type Val<'a> = <Tr as TraceReader>::Val<'a>
Values associated with keys.
Source§type TimeGat<'a> = &'a TInner
type TimeGat<'a> = &'a TInner
Borrowed form of timestamp.
Source§type Diff = <Tr as TraceReader>::Diff
type Diff = <Tr as TraceReader>::Diff
Owned form of update difference.
Source§type DiffGat<'a> = <Tr as TraceReader>::DiffGat<'a>
type DiffGat<'a> = <Tr as TraceReader>::DiffGat<'a>
Borrowed form of update difference.
Source§type Batch = BatchEnter<<Tr as TraceReader>::Batch, TInner>
type Batch = BatchEnter<<Tr as TraceReader>::Batch, TInner>
The type of an immutable collection of updates.
Source§type Storage = <Tr as TraceReader>::Storage
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>
type Cursor = CursorEnter<<Tr as TraceReader>::Cursor, TInner>
The type used to enumerate the collections contents.
Source§fn map_batches<F>(&self, f: F)
fn map_batches<F>(&self, f: F)
Maps logic across the non-empty sequence of batches in the trace. Read more
Source§fn set_logical_compaction(&mut self, frontier: AntichainRef<'_, TInner>)
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>
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>)
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>
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)>
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 moreSource§fn cursor(&mut self) -> (Self::Cursor, Self::Storage)
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>)
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>
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>)
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>
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>)
fn read_upper(&mut self, target: &mut Antichain<Self::Time>)
Reads the upper frontier of committed times.