Trait differential_dataflow::trace::BatchReader [−][src]
A batch of updates whose contents may be read.
This is a restricted interface to batches of updates, which support the reading of the batch’s contents, but do not expose ways to construct the batches. This trait is appropriate for views of the batch, and is especially useful for views derived from other sources in ways that prevent the construction of batches from the type of data in the view (for example, filtered views, or views with extended time coordinates).
Associated Types
type Cursor: Cursor<K, V, T, R, Storage = Self>
[src]
The type used to enumerate the batch’s contents.
Required methods
fn cursor(&self) -> Self::Cursor
[src]
Acquires a cursor to the batch’s contents.
fn len(&self) -> usize
[src]
The number of updates in the batch.
fn description(&self) -> &Description<T>
[src]
Describes the times of the updates in the batch.
Provided methods
fn is_empty(&self) -> bool
[src]
True if the batch is empty.
fn lower(&self) -> &Antichain<T>
[src]
All times in the batch are greater or equal to an element of lower
.
fn upper(&self) -> &Antichain<T>
[src]
All times in the batch are not greater or equal to any element of upper
.
Implementations on Foreign Types
impl<K, V, T, R, B: BatchReader<K, V, T, R>> BatchReader<K, V, T, R> for Rc<B>
[src]
type Cursor = RcBatchCursor<K, V, T, R, B>
The type used to enumerate the batch’s contents.
fn cursor(&self) -> Self::Cursor
[src]
Acquires a cursor to the batch’s contents.
fn len(&self) -> usize
[src]
The number of updates in the batch.
fn description(&self) -> &Description<T>
[src]
Describes the times of the updates in the batch.
impl<K, V, T, R, B: BatchReader<K, V, T, R> + Abomonation> BatchReader<K, V, T, R> for Abomonated<B, Vec<u8>>
[src]
type Cursor = AbomonatedBatchCursor<K, V, T, R, B>
The type used to enumerate the batch’s contents.
fn cursor(&self) -> Self::Cursor
[src]
Acquires a cursor to the batch’s contents.
fn len(&self) -> usize
[src]
The number of updates in the batch.
fn description(&self) -> &Description<T>
[src]
Describes the times of the updates in the batch.
Implementors
impl<K, T, R, O> BatchReader<K, (), T, R> for OrdKeyBatch<K, T, R, O> where
K: Ord + Clone + 'static,
T: Lattice + Ord + Clone + 'static,
R: Semigroup,
O: OrdOffset,
<O as TryFrom<usize>>::Error: Debug,
<O as TryInto<usize>>::Error: Debug,
[src]
K: Ord + Clone + 'static,
T: Lattice + Ord + Clone + 'static,
R: Semigroup,
O: OrdOffset,
<O as TryFrom<usize>>::Error: Debug,
<O as TryInto<usize>>::Error: Debug,
type Cursor = OrdKeyCursor<T, R, O>
fn cursor(&self) -> Self::Cursor
[src]
fn len(&self) -> usize
[src]
fn description(&self) -> &Description<T>
[src]
impl<K, V, T, R, B> BatchReader<K, V, T, R> for BatchFrontier<K, V, T, R, B> where
B: BatchReader<K, V, T, R>,
T: Timestamp + Lattice,
[src]
B: BatchReader<K, V, T, R>,
T: Timestamp + Lattice,
type Cursor = BatchCursorFrontier<K, V, T, R, B>
fn cursor(&self) -> Self::Cursor
[src]
fn len(&self) -> usize
[src]
fn description(&self) -> &Description<T>
[src]
impl<K, V, T, R, B, F> BatchReader<K, V, T, R> for BatchFilter<K, V, T, R, B, F> where
B: BatchReader<K, V, T, R>,
T: Timestamp,
F: FnMut(&K, &V) -> bool + Clone + 'static,
[src]
B: BatchReader<K, V, T, R>,
T: Timestamp,
F: FnMut(&K, &V) -> bool + Clone + 'static,
type Cursor = BatchCursorFilter<K, V, T, R, B, F>
fn cursor(&self) -> Self::Cursor
[src]
fn len(&self) -> usize
[src]
fn description(&self) -> &Description<T>
[src]
impl<K, V, T, R, B, F> BatchReader<K, V, T, R> for BatchFreeze<K, V, T, R, B, F> where
B: BatchReader<K, V, T, R>,
T: Clone,
F: Fn(&T) -> Option<T>,
[src]
B: BatchReader<K, V, T, R>,
T: Clone,
F: Fn(&T) -> Option<T>,
type Cursor = BatchCursorFreeze<K, V, T, R, B, F>
fn cursor(&self) -> Self::Cursor
[src]
fn len(&self) -> usize
[src]
fn description(&self) -> &Description<T>
[src]
impl<K, V, T, R, B, TInner> BatchReader<K, V, TInner, R> for differential_dataflow::trace::wrappers::enter::BatchEnter<K, V, T, R, B, TInner> where
B: BatchReader<K, V, T, R>,
T: Timestamp,
TInner: Refines<T> + Lattice,
[src]
B: BatchReader<K, V, T, R>,
T: Timestamp,
TInner: Refines<T> + Lattice,
type Cursor = BatchCursorEnter<K, V, T, R, B, TInner>
fn cursor(&self) -> Self::Cursor
[src]
fn len(&self) -> usize
[src]
fn description(&self) -> &Description<TInner>
[src]
impl<K, V, T, R, B, TInner, F> BatchReader<K, V, TInner, R> for differential_dataflow::trace::wrappers::enter_at::BatchEnter<K, V, T, R, B, TInner, F> where
B: BatchReader<K, V, T, R>,
T: Timestamp,
TInner: Refines<T> + Lattice,
F: FnMut(&K, &V, &T) -> TInner + Clone,
[src]
B: BatchReader<K, V, T, R>,
T: Timestamp,
TInner: Refines<T> + Lattice,
F: FnMut(&K, &V, &T) -> TInner + Clone,
type Cursor = BatchCursorEnter<K, V, T, R, B, TInner, F>
fn cursor(&self) -> Self::Cursor
[src]
fn len(&self) -> usize
[src]
fn description(&self) -> &Description<TInner>
[src]
impl<K, V, T, R, O> BatchReader<K, V, T, R> for OrdValBatch<K, V, T, R, O> where
K: Ord + Clone + 'static,
V: Ord + Clone + 'static,
T: Lattice + Ord + Clone + 'static,
R: Semigroup,
O: OrdOffset,
<O as TryFrom<usize>>::Error: Debug,
<O as TryInto<usize>>::Error: Debug,
[src]
K: Ord + Clone + 'static,
V: Ord + Clone + 'static,
T: Lattice + Ord + Clone + 'static,
R: Semigroup,
O: OrdOffset,
<O as TryFrom<usize>>::Error: Debug,
<O as TryInto<usize>>::Error: Debug,