Trait differential_dataflow::trace::Builder[−][src]

pub trait Builder<K, V, T, R, Output: Batch<K, V, T, R>> {
    fn new() -> Self;

    fn with_capacity(cap: usize) -> Self;

    fn push(&mut self, element: (K, V, T, R));

    fn done(
        self, 
        lower: Antichain<T>, 
        upper: Antichain<T>, 
        since: Antichain<T>
    ) -> Output;

    fn extend<I: Iterator<Item = (K, V, T, R)>>(&mut self, iter: I) { ... }
}

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]

Completes building and returns the batch.

Loading content...

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.

Loading content...

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]

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.

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.

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]

Loading content...