Trait differential_dataflow::collection::AsCollection

pub trait AsCollection<G: Scope, D: Data, R: Semigroup> {
    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.

Implementations on Foreign Types

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

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

Implementors