Type Alias timely::dataflow::scopes::child::Iterative

pub type Iterative<'a, G, T> = Child<'a, G, Product<<G as ScopeParent>::Timestamp, T>>;

Type alias for iterative child scope.

Aliased Type

struct Iterative<'a, G, T> {
    pub subgraph: &'a RefCell<SubgraphBuilder<<G as ScopeParent>::Timestamp, Product<<G as ScopeParent>::Timestamp, T>>>,
    pub parent: G,
    pub logging: Option<Logger<TimelyEvent, usize>>,
    pub progress_logging: Option<Logger<TimelyProgressEvent, usize>>,
}

Fields

subgraph: &'a RefCell<SubgraphBuilder<<G as ScopeParent>::Timestamp, Product<<G as ScopeParent>::Timestamp, T>>>

The subgraph under assembly.

parent: G

A copy of the child’s parent scope.

logging: Option<Logger<TimelyEvent, usize>>

The log writer for this scope.

progress_logging: Option<Logger<TimelyProgressEvent, usize>>

The progress log writer for this scope.

Trait Implementations

impl<'a, G: Scope, T: Timestamp> LoopVariable<'a, G, T> for Iterative<'a, G, T>

fn loop_variable<C: Container>( &mut self, summary: T::Summary ) -> (Handle<Iterative<'a, G, T>, C>, StreamCore<Iterative<'a, G, T>, C>)

Creates a StreamCore and a Handle to later bind the source of that StreamCore.