Function differential_dataflow::algorithms::prefix_sum::broadcast [−][src]
pub fn broadcast<G, K, D, F>(
ranges: Collection<G, ((usize, usize, K), D)>,
queries: Collection<G, (usize, K)>,
zero: D,
combine: F
) -> Collection<G, ((usize, K), D)> where
G: Scope,
G::Timestamp: Lattice + Ord + Debug,
K: ExchangeData + Hash,
D: ExchangeData + Hash,
F: Fn(&K, &D, &D) -> D + 'static,
Produces the accumulated values at each of the usize
locations in queries
.