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.