Struct differential_dataflow::trace::rc_blanket_impls::RcBatcher

pub struct RcBatcher<K, V, T, R, B: Batch<K, V, T, R>> { /* fields omitted */ }

Wrapper type for batching reference counted batches.

Trait Implementations

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

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: &[T]) -> Rc<B>

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

fn frontier(&mut self) -> &[T]

Returns the lower envelope of contained update times.