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>>,
    pub progress_logging: Option<Logger<TimelyProgressEvent>>,
}

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

The log writer for this scope.

progress_logging: Option<Logger<TimelyProgressEvent>>

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 + Data>( &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.