Trait differential_dataflow::trace::Builder [−][src]
Functionality for building batches from ordered update sequences.
Required methods
fn new() -> Self
[src]
Allocates an empty builder.
fn with_capacity(cap: usize) -> Self
[src]
Allocates an empty builder with some capacity.
fn push(&mut self, element: (K, V, T, R))
[src]
Adds an element to the batch.
fn done(
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> Output
[src]
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> Output
Completes building and returns the batch.
Provided methods
fn extend<I: Iterator<Item = (K, V, T, R)>>(&mut self, iter: I)
[src]
Adds an ordered sequence of elements to the batch.
Implementors
impl<K, T, R, O> Builder<K, (), T, R, OrdKeyBatch<K, T, R, O>> for OrdKeyBuilder<K, T, R, O> where
K: Ord + Clone + 'static,
T: Lattice + Timestamp + 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 + Timestamp + Ord + Clone + 'static,
R: Semigroup,
O: OrdOffset,
<O as TryFrom<usize>>::Error: Debug,
<O as TryInto<usize>>::Error: Debug,
fn new() -> Self
[src]
fn with_capacity(cap: usize) -> Self
[src]
fn push(&mut self, (key, _, time, diff): (K, (), T, R))
[src]
fn done(
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> OrdKeyBatch<K, T, R, O>
[src]
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> OrdKeyBatch<K, T, R, O>
impl<K, V, T, R, B: Batch<K, V, T, R> + Abomonation> Builder<K, V, T, R, Abomonated<B, Vec<u8, Global>>> for AbomonatedBuilder<K, V, T, R, B>
[src]
Functionality for building batches from ordered update sequences.
fn new() -> Self
[src]
fn with_capacity(cap: usize) -> Self
[src]
fn push(&mut self, element: (K, V, T, R))
[src]
fn done(
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> Abomonated<B, Vec<u8>>
[src]
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> Abomonated<B, Vec<u8>>
impl<K, V, T, R, B: Batch<K, V, T, R>> Builder<K, V, T, R, Rc<B>> for RcBuilder<K, V, T, R, B>
[src]
Functionality for building batches from ordered update sequences.
fn new() -> Self
[src]
fn with_capacity(cap: usize) -> Self
[src]
fn push(&mut self, element: (K, V, T, R))
[src]
fn done(
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> Rc<B>
[src]
self,
lower: Antichain<T>,
upper: Antichain<T>,
since: Antichain<T>
) -> Rc<B>
impl<K, V, T, R, O> Builder<K, V, T, R, OrdValBatch<K, V, T, R, O>> for OrdValBuilder<K, V, T, R, O> where
K: Ord + Clone + 'static,
V: Ord + Clone + 'static,
T: Lattice + Timestamp + Ord + Clone + Debug + '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 + Timestamp + Ord + Clone + Debug + 'static,
R: Semigroup,
O: OrdOffset,
<O as TryFrom<usize>>::Error: Debug,
<O as TryInto<usize>>::Error: Debug,