Enum mz_compute::render::context::MzArrangement

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

An abstraction of an arrangement.

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

Variants

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

Implementations

impl<S: Scope> MzArrangement<S>

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

pub fn scope(&self) -> S

The scope of the underlying arrangement’s stream.

pub fn expire_arrangement_at( &mut self, name: &str, expiration: S::Timestamp, token: Weak<()>, )

Panic if the frontier of the underlying arrangement’s stream exceeds expiration time.

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

Brings the underlying arrangement 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 arrangement as a stream of updates.

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

where T: Timestamp + Lattice + Columnation, <S as ScopeParent>::Timestamp: Lattice + Refines<T>, 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> MzArrangement<Child<'a, S, S::Timestamp>>

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

pub fn leave_region(&self) -> MzArrangement<S>

Extracts the underlying arrangement flavor from a region.

impl<S> MzArrangement<S>

where S: ScopeParent<Timestamp = Timestamp> + Scope,

pub fn trace_handle(&self) -> SpecializedTraceHandle

Obtains a SpecializedTraceHandle for the underlying arrangement.

Trait Implementations

impl<S: Clone + Scope> Clone for MzArrangement<S>

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

fn clone(&self) -> MzArrangement<S>

Returns a copy of the value.

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

Performs copy-assignment from source.