Trait Arrange 

pub trait Arrange<'scope, T: Timestamp + Lattice, C>: Sized {
    // Required method
    fn arrange_named<Ba, Bu, Tr>(
        self,
        name: &str,
    ) -> Arranged<'scope, TraceAgent<Tr>>
       where Ba: Batcher<Output = C, Time = T> + 'static,
             Bu: Builder<Time = T, Input = Ba::Output, Output = Tr::Batch>,
             Tr: Trace<Time = T> + 'static;

    // Provided method
    fn arrange<Ba, Bu, Tr>(self) -> Arranged<'scope, TraceAgent<Tr>>
       where Ba: Batcher<Output = C, Time = T> + 'static,
             Bu: Builder<Time = T, Input = Ba::Output, Output = Tr::Batch>,
             Tr: Trace<Time = T> + 'static { ... }
}

A type that can be arranged as if a collection of updates.

Required Methods

fn arrange_named<Ba, Bu, Tr>( self, name: &str, ) -> Arranged<'scope, TraceAgent<Tr>>

where Ba: Batcher<Output = C, Time = T> + 'static, Bu: Builder<Time = T, Input = Ba::Output, Output = Tr::Batch>, Tr: Trace<Time = T> + 'static,

Arranges updates into a shared trace, with a supplied name.

See Arrange::arrange for constraints on the batcher’s output container.

Provided Methods

fn arrange<Ba, Bu, Tr>(self) -> Arranged<'scope, TraceAgent<Tr>>

where Ba: Batcher<Output = C, Time = T> + 'static, Bu: Builder<Time = T, Input = Ba::Output, Output = Tr::Batch>, Tr: Trace<Time = T> + 'static,

Arranges updates into a shared trace.

The batcher’s output container must equal the stream container C; the default chunker only consolidates same-type containers. For chunker setups that convert between container types (e.g. columnar layouts), call arrange_core directly.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<'scope, T, K, V, R> Arrange<'scope, T, Vec<((K, V), T, R)>> for Collection<'scope, T, (K, V), R>

where T: Timestamp + Lattice, K: ExchangeData + Hashable, V: ExchangeData, R: ExchangeData + Semigroup,

impl<'scope, T, K: ExchangeData + Hashable, R: ExchangeData + Semigroup> Arrange<'scope, T, Vec<((K, ()), T, R)>> for Collection<'scope, T, K, R>

where T: Timestamp + Lattice + Ord,