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 Stream into a child of its current Scope.
EnterAt	Extension trait to move a Stream into a child of its current Scope setting the timestamp for each element.
Leave	Extension trait to move a Stream to the parent of its current Scope.