Function timely_util::operators::window_all_parallel
source · pub fn window_all_parallel<D1, D2, D3, I, F, E, T, G>(
name: &str,
in_stream: &Stream<G, D1>,
init: I,
fold: F,
emit: E
) -> Stream<G, D3>where
D1: Data + Debug,
D2: Data + Debug,
D3: Data + Debug,
I: FnOnce() -> D2 + 'static,
F: Fn(&mut D2, &T, Vec<D1>) + 'static,
E: Fn(&D2) -> D3 + 'static,
T: Timestamp + Copy,
G: Scope<Timestamp = T>,