Trait declarative_dataflow::operators::CardinalityOne

pub trait CardinalityOne<S: Scope> {
    fn cardinality_one(&self) -> Collection<S, (Value, Value), isize>;
}

Provides the cardinality_one method.

Required methods

fn cardinality_one(&self) -> Collection<S, (Value, Value), isize>

Ensures that only a single value per eid exists within an attribute, by retracting any previous values upon new updates. Therefore this stream does not expect explicit retractions.

Loading content...

Implementations on Foreign Types

impl<S> CardinalityOne<S> for Collection<S, (Value, Value), isize> where
    S: Scope,
    S::Timestamp: Lattice + Ord, 

fn cardinality_one(&self) -> Collection<S, (Value, Value), isize>

Loading content...

Implementors

Loading content...