Trait differential_dataflow::operators::arrange::arrangement::ArrangeByKey [−][src]
Arranges something as (Key,Val)
pairs according to a type T
of trace.
This arrangement requires Key: Hashable
, and uses the hashed()
method to place keys in a hashed
map. This can result in many hash calls, and in some cases it may help to first transform K
to the
pair (u64, K)
of hash value and key.
Required methods
fn arrange_by_key(
&self
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>
[src]
&self
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>
Arranges a collection of (Key, Val)
records by Key
.
This operator arranges a stream of values into a shared trace, whose contents it maintains. This trace is current for all times completed by the output stream, which can be used to safely identify the stable times and values in the trace.
fn arrange_by_key_named(
&self,
name: &str
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>
[src]
&self,
name: &str
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>
As arrange_by_key
but with the ability to name the arrangement.
Implementors
impl<G: Scope, K: ExchangeData + Hashable, V: ExchangeData, R: ExchangeData + Semigroup> ArrangeByKey<G, K, V, R> for Collection<G, (K, V), R> where
G::Timestamp: Lattice + Ord,
[src]
G::Timestamp: Lattice + Ord,
fn arrange_by_key(
&self
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>
[src]
&self
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>
fn arrange_by_key_named(
&self,
name: &str
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>
[src]
&self,
name: &str
) -> Arranged<G, TraceAgent<DefaultValTrace<K, V, G::Timestamp, R>>>