Skip to main content

aggregate

differential_dataflow::algorithms::prefix_sum

Function aggregate 

Source 
pub fn aggregate<'scope, T, K, D, F>(
    collection: VecCollection<'scope, T, ((usize, K), D)>,
    combine: F,
) -> VecCollection<'scope, T, ((usize, usize, K), D)>
where
    T: Timestamp + Lattice,
    K: ExchangeData + Hash,
    D: ExchangeData + Hash,
    F: Fn(&K, &D, &D) -> D + 'static,
Expand description

Accumulate data in collection into all powers-of-two intervals containing them.