Expand description
Implementation of feedback UPSERT operator and associated helpers. See
upsert_inner
for a description of how the operator works and why.
Enums§
- The style of drain we are performing on the stash.
AtTime
-drains cannot assume that all values have been seen, and must leave tombstones behind for deleted values.
Functions§
- Helper method for
upsert_inner
used to stagedata
updates from the input timely edge. - Helper method for
upsert_inner
used to stagedata
updates from the input/source timely edge. - An operator that transforms an input stream of upserts (updates to key-value pairs), which represents an imaginary key-value state, into a differential collection. It keeps an internal map-like state which keeps the latest value for each key, such that it can emit the retractions and additions implied by a new update for a given key.