pub trait Consolidate<D: ExchangeData + Hashable>: Sized {
    fn consolidate_named(&self, name: &str) -> Self;

    fn consolidate(&self) -> Self { ... }
}
Expand description

An extension method for consolidating weighted streams.

Required Methods§

As consolidate but with the ability to name the operator.

Provided Methods§

Aggregates the weights of equal records into at most one record.

This method uses the type D’s hashed() method to partition the data. The data are accumulated in place, each held back until their timestamp has completed.

Examples
extern crate timely;
extern crate differential_dataflow;

use differential_dataflow::input::Input;
use differential_dataflow::operators::Consolidate;

fn main() {
    ::timely::example(|scope| {

        let x = scope.new_collection_from(1 .. 10u32).1;

        x.negate()
         .concat(&x)
         .consolidate() // <-- ensures cancellation occurs
         .assert_empty();
    });
}

Implementors§