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§
sourcefn consolidate_named(&self, name: &str) -> Self
fn consolidate_named(&self, name: &str) -> Self
As consolidate
but with the ability to name the operator.
Provided Methods§
sourcefn consolidate(&self) -> Self
fn consolidate(&self) -> Self
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();
});
}