Trait mz_compute::extensions::arrange::MzArrange

pub trait MzArrange: MzArrangeCore
where
    <Self::Scope as ScopeParent>::Timestamp: Lattice,
{
    // Required method
    fn mz_arrange<Ba, Bu, Tr>(
        &self,
        name: &str,
    ) -> Arranged<Self::Scope, TraceAgent<Tr>>
       where Ba: Batcher<Input = Self::Input, Time = <Self::Scope as ScopeParent>::Timestamp> + 'static,
             Bu: Builder<Time = <Self::Scope as ScopeParent>::Timestamp, Input = Ba::Output, Output = Tr::Batch>,
             Tr: Trace + TraceReader<Time = <Self::Scope as ScopeParent>::Timestamp> + 'static,
             Tr::Batch: Batch,
             Arranged<Self::Scope, TraceAgent<Tr>>: ArrangementSize;
}

Extension trait to arrange data.

Required Methods

fn mz_arrange<Ba, Bu, Tr>( &self, name: &str, ) -> Arranged<Self::Scope, TraceAgent<Tr>>

where Ba: Batcher<Input = Self::Input, Time = <Self::Scope as ScopeParent>::Timestamp> + 'static, Bu: Builder<Time = <Self::Scope as ScopeParent>::Timestamp, Input = Ba::Output, Output = Tr::Batch>, Tr: Trace + TraceReader<Time = <Self::Scope as ScopeParent>::Timestamp> + 'static, Tr::Batch: Batch, Arranged<Self::Scope, TraceAgent<Tr>>: ArrangementSize,

Arranges a stream of (Key, Val) updates by Key into a trace of type Tr.

This operator arranges a stream of values into a shared trace, whose contents it maintains. This trace is current for all times marked completed in the output stream, and probing this stream is the correct way to determine that times in the shared trace are committed.

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<G, K, V, R> MzArrange for Collection<G, (K, V), R>

where G: Scope, G::Timestamp: Lattice, K: ExchangeData + Hashable, V: ExchangeData, R: ExchangeData,

fn mz_arrange<Ba, Bu, Tr>(&self, name: &str) -> Arranged<G, TraceAgent<Tr>>

where Ba: Batcher<Input = Self::Input, Time = <Self::Scope as ScopeParent>::Timestamp> + 'static, Bu: Builder<Time = <Self::Scope as ScopeParent>::Timestamp, Input = Ba::Output, Output = Tr::Batch>, Tr: Trace + TraceReader<Time = <Self::Scope as ScopeParent>::Timestamp> + 'static, Tr::Batch: Batch, Arranged<G, TraceAgent<Tr>>: ArrangementSize,

Implementors

impl<G, K, R> MzArrange for KeyCollection<G, K, R>

where G: Scope, K: ExchangeData + Hashable, G::Timestamp: Lattice, R: ExchangeData,