Enum ArrangementFlavor

pub enum ArrangementFlavor<S: Scope, T = Timestamp>
where
    T: MzTimestamp,
    S::Timestamp: MzTimestamp + Refines<T>,
{
    Local(Arranged<S, TraceAgent<Spine<Rc<OrdValBatch<RowRowLayout<((Row, Row), S::Timestamp, Diff)>>>>>>, Arranged<S, TraceAgent<Spine<Rc<OrdKeyBatch<MzStack<((DataflowError, ()), S::Timestamp, Diff)>>>>>>),
    Trace(GlobalId, Arranged<S, TraceEnter<TraceFrontier<TraceAgent<Spine<Rc<OrdValBatch<RowRowLayout<((Row, Row), T, Diff)>>>>>>, S::Timestamp>>, Arranged<S, TraceEnter<TraceFrontier<TraceAgent<Spine<Rc<OrdKeyBatch<MzStack<((DataflowError, ()), T, Diff)>>>>>>, S::Timestamp>>),
}

Describes flavor of arrangement: local or imported trace.

Variants

Local(Arranged<S, TraceAgent<Spine<Rc<OrdValBatch<RowRowLayout<((Row, Row), S::Timestamp, Diff)>>>>>>, Arranged<S, TraceAgent<Spine<Rc<OrdKeyBatch<MzStack<((DataflowError, ()), S::Timestamp, Diff)>>>>>>)

A dataflow-local arrangement.

Trace(GlobalId, Arranged<S, TraceEnter<TraceFrontier<TraceAgent<Spine<Rc<OrdValBatch<RowRowLayout<((Row, Row), T, Diff)>>>>>>, S::Timestamp>>, Arranged<S, TraceEnter<TraceFrontier<TraceAgent<Spine<Rc<OrdKeyBatch<MzStack<((DataflowError, ()), T, Diff)>>>>>>, S::Timestamp>>)

An imported trace from outside the dataflow.

The GlobalId identifier exists so that exports of this same trace can refer back to and depend on the original instance.

Implementations

impl<S: Scope, T> ArrangementFlavor<S, T>

where T: MzTimestamp, S::Timestamp: MzTimestamp + Refines<T>,

pub fn as_collection( &self, ) -> (Collection<S, Row, Diff>, Collection<S, DataflowError, Diff>)

👎Deprecated: Use flat_map instead.

Presents self as a stream of updates.

Deprecated: This function is not fueled and hence risks flattening the whole arrangement.

This method presents the contents as they are, without further computation. If you have logic that could be applied to each record, consider using the flat_map methods which allows this and can reduce the work done.

pub fn flat_map<D, I, L>( &self, key: Option<&Row>, max_demand: usize, logic: L, ) -> (Stream<S, I::Item>, Collection<S, DataflowError, Diff>)

where I: IntoIterator<Item = (D, S::Timestamp, Diff)>, D: Data, L: for<'a, 'b> FnMut(&'a mut DatumVecBorrow<'b>, S::Timestamp, Diff) -> I + 'static,

Constructs and applies logic to elements of self and returns the results.

The logic receives a vector of datums, a timestamp, and a diff, and produces an iterator of (D, S::Timestamp, Diff) updates.

If key is set, this is a promise that logic will produce no results on records for which the key does not evaluate to the value. This is used to leap directly to exactly those records.

The max_demand parameter limits the number of columns decoded from the input. Only the first max_demand columns are decoded. Pass usize::MAX to decode all columns.

impl<S: Scope, T> ArrangementFlavor<S, T>

where T: MzTimestamp, S::Timestamp: MzTimestamp + Refines<T>,

pub fn scope(&self) -> S

The scope containing the collection bundle.

pub fn enter_region<'a>( &self, region: &Child<'a, S, S::Timestamp>, ) -> ArrangementFlavor<Child<'a, S, S::Timestamp>, T>

Brings the arrangement flavor into a region.

impl<'a, S: Scope, T> ArrangementFlavor<Child<'a, S, S::Timestamp>, T>

where T: MzTimestamp, S::Timestamp: MzTimestamp + Refines<T>,

pub fn leave_region(&self) -> ArrangementFlavor<S, T>

Extracts the arrangement flavor from a region.

Trait Implementations

impl<S: Clone + Scope, T> Clone for ArrangementFlavor<S, T>

where T: MzTimestamp + Clone, S::Timestamp: MzTimestamp + Refines<T> + Clone,

fn clone(&self) -> ArrangementFlavor<S, T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.