[−][src]Trait differential_dataflow::trace::Batch
An immutable collection of updates.
Associated Types
type Batcher: Batcher<K, V, T, R, Self>
A type used to assemble batches from disordered updates.
type Builder: Builder<K, V, T, R, Self>
A type used to assemble batches from ordered update sequences.
type Merger: Merger<K, V, T, R, Self>
A type used to progressively merge batches.
Provided methods
fn begin_merge(&self, other: &Self) -> Self::Merger
Initiates the merging of consecutive batches.
The result of this method can be exercised to eventually produce the same result
that a call to self.merge(other)
would produce, but it can be done in a measured
fashion. This can help to avoid latency spikes where a large merge needs to happen.
Implementations on Foreign Types
impl<K, V, T, R, B: Batch<K, V, T, R>> Batch<K, V, T, R> for Rc<B>
[src]
An immutable collection of updates.
type Batcher = RcBatcher<K, V, T, R, B>
type Builder = RcBuilder<K, V, T, R, B>
type Merger = RcMerger<K, V, T, R, B>
fn begin_merge(&self, other: &Self) -> Self::Merger
[src]
impl<K, V, T, R, B: Batch<K, V, T, R> + Abomonation> Batch<K, V, T, R> for Abomonated<B, Vec<u8>>
[src]
An immutable collection of updates.
type Batcher = AbomonatedBatcher<K, V, T, R, B>
type Builder = AbomonatedBuilder<K, V, T, R, B>
type Merger = AbomonatedMerger<K, V, T, R, B>
fn begin_merge(&self, other: &Self) -> Self::Merger
[src]
Implementors
impl<K, T, R> Batch<K, (), T, R> for OrdKeyBatch<K, T, R> where
K: Ord + Clone + 'static,
T: Lattice + Ord + Clone + 'static,
R: Monoid,
[src]
K: Ord + Clone + 'static,
T: Lattice + Ord + Clone + 'static,
R: Monoid,
type Batcher = MergeBatcher<K, (), T, R, Self>
type Builder = OrdKeyBuilder<K, T, R>
type Merger = OrdKeyMerger<K, T, R>
fn begin_merge(&self, other: &Self) -> Self::Merger
[src]
impl<K, V, T, R> Batch<K, V, T, R> for OrdValBatch<K, V, T, R> where
K: Ord + Clone + 'static,
V: Ord + Clone + 'static,
T: Lattice + Ord + Clone + Debug + 'static,
R: Monoid,
[src]
K: Ord + Clone + 'static,
V: Ord + Clone + 'static,
T: Lattice + Ord + Clone + Debug + 'static,
R: Monoid,