Enum mz_compute::render::context::MzArrangementImport

pub enum MzArrangementImport<S: Scope, T = Timestamp>
where
    T: Timestamp + Lattice + Columnation,
    <S as ScopeParent>::Timestamp: Lattice + Refines<T>,
{
    RowRow(Arranged<S, TraceEnter<TraceFrontier<TraceAgent<Spine<Rc<OrdValBatch<RowRowLayout<((Row, Row), T, Diff)>>>>>>, <S as ScopeParent>::Timestamp>>),
}

An abstraction of an imported arrangement.

This type exists as an enum to support potential experimentation with alternate representation and layouts.

Variants

RowRow(Arranged<S, TraceEnter<TraceFrontier<TraceAgent<Spine<Rc<OrdValBatch<RowRowLayout<((Row, Row), T, Diff)>>>>>>, <S as ScopeParent>::Timestamp>>)

Implementations

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

where T: Timestamp + Lattice + Columnation, <S as ScopeParent>::Timestamp: Lattice + Refines<T> + Columnation,

pub fn scope(&self) -> S

The scope of the underlying trace’s stream.

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

Brings the underlying trace into a region.

pub fn as_collection<L>(&self, logic: L) -> Collection<S, Row, Diff>

where L: for<'a, 'b> FnMut(&'a DatumVecBorrow<'b>) -> Row + 'static,

Extracts the underlying trace as a stream of updates.

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

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

Applies logic to elements of the underlying arrangement and returns the results.

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

where T: Timestamp + Lattice + Columnation, <S as ScopeParent>::Timestamp: Lattice + Refines<T>,

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

Extracts the underlying arrangement flavor from a region.

Trait Implementations

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

where T: Timestamp + Lattice + Columnation + Clone, <S as ScopeParent>::Timestamp: Lattice + Refines<T>,

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S> WithStartSignal for MzArrangementImport<S>

where S: Scope, S::Timestamp: RenderTimestamp,

fn with_start_signal(self, signal: StartSignal) -> Self

Delays data and progress updates until the start signal has fired.