Trait differential_dataflow::collection::AsCollection

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

Conversion to a differential dataflow Collection.

Required Methods

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

Converts the type to a differential dataflow collection.

Implementors

• impl<G: Scope, D: Data, R: Diff> AsCollection<G, D, R> for Stream<G, (D, G::Timestamp, R)>