Trait differential_dataflow::operators::iterate::IterateExt [−] [src]

pub trait IterateExt<G: Scope, D: Data> {
    fn iterate<F>(&self, logic: F) -> Collection<G, D> where G::Timestamp: LeastUpperBound, F: FnOnce(&Collection<Child<'a, G, u64>, D>) -> Collection<Child<'a, G, u64>, D>;
}

An extension trait for the iterate method.

Required Methods

fn iterate<F>(&self, logic: F) -> Collection<G, D> where G::Timestamp: LeastUpperBound, F: FnOnce(&Collection<Child<'a, G, u64>, D>) -> Collection<Child<'a, G, u64>, D>

Iteratively apply logic to the source collection until convergence.

Implementors