Trait differential_dataflow::operators::threshold::ThresholdUnsigned [−] [src]

pub trait ThresholdUnsigned<G: Scope, U: Unsigned + Data + Default> where G::Timestamp: LeastUpperBound {
    fn threshold_u<L>(&self, logic: L) -> Collection<G, U> where L: Fn(&U, Delta) -> Delta + 'static;

    fn distinct_u(&self) -> Collection<G, U> { ... }
}

Extension trait for the group_u differential dataflow method.

Required Methods

fn threshold_u<L>(&self, logic: L) -> Collection<G, U> where L: Fn(&U, Delta) -> Delta + 'static

Groups records by their first field, when this field implements Unsigned.

This method uses a Vec<Option<_>> as its internal storage, allocating enough memory to directly index based on the first fields. This can be very useful when these fields are small integers, but it can be expensive if they are large and sparse.

Provided Methods

fn distinct_u(&self) -> Collection<G, U>

Collects distinct elements, when they implement Unsigned.

Implementors