Function differential_dataflow::operators::arrange::upsert::arrange_from_upsert [−][src]
pub fn arrange_from_upsert<G, Tr>(
stream: &Stream<G, (Tr::Key, Option<Tr::Val>, G::Timestamp)>,
name: &str
) -> Arranged<G, TraceAgent<Tr>> where
G: Scope,
G::Timestamp: Lattice + Ord + TotalOrder + ExchangeData,
Tr::Key: ExchangeData + Hashable + Hash,
Tr::Val: ExchangeData,
Tr: Trace + TraceReader<Time = G::Timestamp, R = isize> + 'static,
Tr::Batch: Batch<Tr::Key, Tr::Val, G::Timestamp, isize>,
Tr::Cursor: Cursor<Tr::Key, Tr::Val, G::Timestamp, isize>,
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.