[−][src]Trait differential_dataflow::algorithms::identifiers::Identifiers
Assign unique identifiers to elements of a collection.
Required methods
fn identifiers(&self) -> Collection<G, (D, u64), R>
Assign unique identifiers to elements of a collection.
Example
extern crate timely; extern crate differential_dataflow; use differential_dataflow::input::Input; use differential_dataflow::algorithms::identifiers::Identifiers; use differential_dataflow::operators::Threshold; fn main() { ::timely::example(|scope| { let identifiers = scope.new_collection_from(1 .. 10).1 .identifiers() // assert no conflicts .map(|(data, id)| id) .threshold(|_id,cnt| if cnt > &1 { *cnt } else { 0 }) .assert_empty(); }); }
Implementors
impl<G, D, R> Identifiers<G, D, R> for Collection<G, D, R> where
G: Scope,
G::Timestamp: Lattice,
D: ExchangeData + Hash,
R: ExchangeData + Abelian,
[src]
G: Scope,
G::Timestamp: Lattice,
D: ExchangeData + Hash,
R: ExchangeData + Abelian,