Trait differential_dataflow::operators::arrange::arrangement::Arrange

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

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

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

Required Methods

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

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

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

Provided Methods

fn arrange<Ba, Bu, Tr>(&self) -> Arranged<G, TraceAgent<Tr>>

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

Arranges updates into a shared trace.

Object Safety

This trait is not object safe.

Implementors

impl<G, K, V, R> Arrange<G, Vec<((K, V), <G as ScopeParent>::Timestamp, R)>> for Collection<G, (K, V), R>

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

impl<G: Scope, K: ExchangeData + Hashable, R: ExchangeData + Semigroup> Arrange<G, Vec<((K, ()), <G as ScopeParent>::Timestamp, R)>> for Collection<G, K, R>

where G::Timestamp: Lattice + Ord,