Trait differential_dataflow::AsCollection

pub trait AsCollection<G: Scope, D: Data> {
    fn as_collection(&self) -> Collection<G, D>;
}

Conversion to a differential dataflow collection.

Required Methods

fn as_collection(&self) -> Collection<G, D>

Conversion to a differential dataflow collection.

Implementors

• impl<G: Scope, D: Data> AsCollection<G, D> for Stream<G, (D, Delta)>