Trait AsCollection

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

Conversion to a differential dataflow Collection.

Required Methods

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

Converts the type to a differential dataflow collection.

Implementations on Foreign Types

impl<G: Scope, D, R, C: Clone> AsCollection<G, D, R, C> for StreamCore<G, C>

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

Converts the type to a differential dataflow collection.

By calling this method, you guarantee that the timestamp invariant (as documented on Collection) is upheld. This method will not check it.

Implementors