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

source · 
pub fn arrange_core<G, P, Tr>(
    stream: &StreamCore<G, <Tr::Batcher as Batcher>::Input>,
    pact: P,
    name: &str
) -> Arranged<G, TraceAgent<Tr>>
where
    G: Scope,
    G::Timestamp: Lattice,
    P: ParallelizationContract<G::Timestamp, <Tr::Batcher as Batcher>::Input>,
    Tr: Trace<Time = G::Timestamp> + 'static,
    Tr::Batch: Batch,
    <Tr::Batcher as Batcher>::Input: Container,
Expand description

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).