differential_dataflow::collection

Trait AsCollection

Source 
pub trait AsCollection<G: Scope, D: Data, R: Semigroup> {
    // Required method
    fn as_collection(&self) -> Collection<G, D, R>;
}
Expand description

Conversion to a differential dataflow Collection.

Required Methods§

Source

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

Converts the type to a differential dataflow collection.

Implementations on Foreign Types§

Source§

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

Source§

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

Implementors§