Trait differential_dataflow::trace::Batch

pub trait Batch<K, V, T, R>: BatchReader<K, V, T, R> where
    Self: Sized, {
    type Batcher: Batcher<K, V, T, R, Self>;
    type Builder: Builder<K, V, T, R, Self>;
    type Merger: Merger<K, V, T, R, Self>;
    fn begin_merge(&self, other: &Self) -> Self::Merger { ... }
}

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>

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

impl<K, V, T, R, B: Batch<K, V, T, R> + Abomonation> Batch<K, V, T, R> for Abomonated<B, Vec<u8>>

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

Implementors

• 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: Diff,  type Batcher = MergeBatcher<K, V, T, R, Self>; type Builder = OrdValBuilder<K, V, T, R>; type Merger = OrdValMerger<K, V, T, R>;

• impl<K, T, R> Batch<K, (), T, R> for OrdKeyBatch<K, T, R> where     K: Ord + Clone + 'static,     T: Lattice + Ord + Clone + 'static,     R: Diff,  type Batcher = MergeBatcher<K, (), T, R, Self>; type Builder = OrdKeyBuilder<K, T, R>; type Merger = OrdKeyMerger<K, T, R>;