Function differential_dataflow::operators::arrange::arrangement::arrange_core

pub fn arrange_core<G, P, Ba, Bu, Tr>(
    stream: &StreamCore<G, Ba::Input>,
    pact: P,
    name: &str,
) -> Arranged<G, TraceAgent<Tr>>
where
    G: Scope,
    G::Timestamp: Lattice,
    P: ParallelizationContract<G::Timestamp, Ba::Input>,
    Ba: Batcher<Time = G::Timestamp> + 'static,
    Ba::Input: Container + Clone + 'static,
    Bu: Builder<Time = G::Timestamp, Input = Ba::Output, Output = Tr::Batch>,
    Tr: Trace<Time = G::Timestamp> + 'static,
    Tr::Batch: Batch,

Arranges a stream of updates by a key, configured with a name and a parallelization contract.

This operator arranges a stream of values into a shared trace, whose contents it maintains. It uses the supplied parallelization contract to distribute the data, which does not need to be consistently by key (though this is the most common).