[−][src]Module timely::dataflow::operators::enterleave
Extension traits to move a Stream
between an outer Scope
and inner Scope
.
Each Stream
indicates its containing Scope
as part of its type signature. To create a new
stream with the same contents in another scope, one must explicit use the methods enter
and
leave
, to clearly indicate the transition to the timely dataflow progress tracking logic.
Examples
use timely::dataflow::scopes::Scope; use timely::dataflow::operators::{Enter, Leave, ToStream, Inspect}; timely::example(|outer| { let stream = (0..9).to_stream(outer); let output = outer.region(|inner| { stream.enter(inner) .inspect(|x| println!("in nested scope: {:?}", x)) .leave() }); });
Traits
Enter | Extension trait to move a |
EnterAt | Extension trait to move a |
Leave | Extension trait to move a |