Trait differential_dataflow::trace::Batcher

pub trait Batcher<K, V, T, R, Output: Batch<K, V, T, R>> {
    fn new() -> Self;
    fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>);
    fn seal(&mut self, upper: Antichain<T>) -> Output;
    fn frontier(&mut self) -> AntichainRef<'_, T>;
}

Functionality for collecting and batching updates.

Required methods

fn new() -> Self

Allocates a new empty batcher.

fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>)

Adds an unordered batch of elements to the batcher.

fn seal(&mut self, upper: Antichain<T>) -> Output

Returns all updates not greater or equal to an element of upper.

fn frontier(&mut self) -> AntichainRef<'_, T>

Returns the lower envelope of contained update times.

Loading content...

Implementors

impl<K, V, T, R, B> Batcher<K, V, T, R, B> for MergeBatcher<K, V, T, R, B> where
    K: Ord + Clone,
    V: Ord + Clone,
    T: Lattice + Timestamp + Ord + Clone,
    R: Semigroup,
    B: Batch<K, V, T, R>, 

fn new() -> Self

fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>)

fn seal(&mut self, upper: Antichain<T>) -> B

fn frontier(&mut self) -> AntichainRef<'_, T>

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

Functionality for collecting and batching updates.

fn new() -> Self

fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>)

fn seal(&mut self, upper: Antichain<T>) -> Abomonated<B, Vec<u8>>

fn frontier(&mut self) -> AntichainRef<'_, T>

impl<K, V, T, R, B: Batch<K, V, T, R>> Batcher<K, V, T, R, Rc<B>> for RcBatcher<K, V, T, R, B>

Functionality for collecting and batching updates.

fn new() -> Self

fn push_batch(&mut self, batch: &mut Vec<((K, V), T, R)>)

fn seal(&mut self, upper: Antichain<T>) -> Rc<B>

fn frontier(&mut self) -> AntichainRef<'_, T>

Loading content...