Enum dataflow::render::reduce::ArrangementOrCollection

enum ArrangementOrCollection<G> where
    G: Scope,
    G::Timestamp: Lattice,  {
    Arrangement(Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>),
    Collection(Collection<G, Row>),
}

A type wrapping either an arrangement or a single collection.

Variants

Arrangement(Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>)

Tuple Fields

0: Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>

Wrap an arrangement

Collection(Collection<G, Row>)

Tuple Fields

0: Collection<G, Row>

Wrap a collection

Implementations

impl<G> ArrangementOrCollection<G> where
    G: Scope,
    G::Timestamp: Lattice, 

fn into_bundle<T>(
    self,
    key_arity: usize,
    err_input: Collection<G, DataflowError>
) -> CollectionBundle<G, Row, T> where
    G::Timestamp: Lattice + Refines<T>,
    T: Timestamp + Lattice, 

Convert to a CollectionBundle by either supplying the arrangement or construction from collections.

• key_arity - The number of columns in the key. Only used for arrangement variants.
• err_input - A collection containing the error stream.

Trait Implementations

impl<G> From<Arranged<G, TraceAgent<Spine<Row, Row, <G as ScopeParent>::Timestamp, isize, Rc<OrdValBatch<Row, Row, <G as ScopeParent>::Timestamp, isize, usize>>>>>> for ArrangementOrCollection<G> where
    G: Scope,
    G::Timestamp: Lattice, 

fn from(
    arrangement: Arranged<G, TraceAgent<OrdValSpine<Row, Row, <G as ScopeParent>::Timestamp, Diff, usize>>>
) -> Self

Performs the conversion.

impl<G> From<Collection<G, Row, isize>> for ArrangementOrCollection<G> where
    G: Scope,
    G::Timestamp: Lattice, 

fn from(collection: Collection<G, Row>) -> Self

Performs the conversion.