[−][src]Trait timely::dataflow::operators::enterleave::EnterAt
Extension trait to move a Stream
into a child of its current Scope
setting the timestamp for each element.
Required methods
fn enter_at<'a, F: Fn(&D) -> T + 'static>(
&self,
scope: &Iterative<'a, G, T>,
initial: F
) -> Stream<Iterative<'a, G, T>, D>
&self,
scope: &Iterative<'a, G, T>,
initial: F
) -> Stream<Iterative<'a, G, T>, D>
Moves the Stream
argument into a child of its current Scope
setting the timestamp for each element by initial
.
Examples
use timely::dataflow::scopes::Scope; use timely::dataflow::operators::{EnterAt, Leave, ToStream}; timely::example(|outer| { let stream = (0..9u64).to_stream(outer); let output = outer.iterative(|inner| { stream.enter_at(inner, |x| *x).leave() }); });