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: Lattice,
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: Lattice,
F: FnOnce(&Collection<Child<'a, G, u64>, D>) -> Collection<Child<'a, G, u64>, D>,
G::Timestamp: Lattice,
F: FnOnce(&Collection<Child<'a, G, u64>, D>) -> Collection<Child<'a, G, u64>, D>,
Iteratively apply logic to the source collection until convergence.
Implementors
impl<G: Scope, D: Ord + Data + Debug> IterateExt<G, D> for Collection<G, D>