[−][src]Trait timely::dataflow::operators::enterleave::EnterAt

pub trait EnterAt<G: Scope, T: Timestamp, D: Data> {
    fn enter_at<'a, F: Fn(&D) -> T + 'static>(
        &self, 
        scope: &Iterative<'a, G, T>, 
        initial: F
    ) -> Stream<Iterative<'a, G, T>, D>;
}

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>`

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()
    });
});

Loading content...

Implementors

`impl<G: Scope, T: Timestamp, D: Data, E: Enter<G, Product<<G as ScopeParent>::Timestamp, T>, D>> EnterAt<G, T, D> for E`[src]

`fn enter_at<'a, F: Fn(&D) -> T + 'static>( &self, scope: &Iterative<'a, G, T>, initial: F ) -> Stream<Iterative<'a, G, T>, D>`[src]