Trait differential_dataflow::algorithms::identifiers::Identifiers

pub trait Identifiers<G: Scope, D: ExchangeData, R: ExchangeData + Abelian> {
    // Required method
    fn identifiers(&self) -> Collection<G, (D, u64), R>;
}

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

use differential_dataflow::input::Input;
use differential_dataflow::algorithms::identifiers::Identifiers;
use differential_dataflow::operators::Threshold;

::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,