Module mz_storage::upsert_continual_feedback

source ·
Expand description

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.