Function differential_dataflow::operators::arrange::upsert::arrange_from_upsert
source · pub fn arrange_from_upsert<G, Tr>(
stream: &Stream<G, (Tr::KeyOwned, Option<Tr::ValOwned>, G::Timestamp)>,
name: &str
) -> Arranged<G, TraceAgent<Tr>>where
G: Scope<Timestamp = Tr::Time>,
Tr: Trace + TraceReader<Diff = isize> + 'static,
Tr::KeyOwned: ExchangeData + Hashable + Hash,
Tr::ValOwned: ExchangeData,
Tr::Time: TotalOrder + ExchangeData,
Tr::Batch: Batch,
Tr::Builder: Builder<Input = ((Tr::KeyOwned, Tr::ValOwned), Tr::Time, Tr::Diff)>,
Expand description
Arrange data from a stream of keyed upserts.
The input should be a stream of timestamped pairs of Key and Option
This method is only implemented for totally ordered times, as we do not yet understand what a “sequence” of upserts would mean for partially ordered timestamps.