Module upsert_continual_feedback

Implementation of feedback UPSERT operator and associated helpers. See upsert_inner for a description of how the operator works and why.

Enums

• DrainStyle 🔒
  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

• drain_staged_input 🔒
  Helper method for upsert_inner used to stage data updates from the input timely edge.
• stage_input 🔒
  Helper method for upsert_inner used to stage data updates from the input/source timely edge.
• upsert_inner
  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.