Skip to main content

Module feedback

Module feedback 

Source
Expand description

The persist-feedback side of the upsert-v2 operator: the feedback arrangement’s types, and the UpsertValue to Row encoding it stores.

Functions§

decode_upsert_value 🔒
Decode an UpsertValue produced by [upsert_value_to_row] from any datum iterator, whether over a columnar Row reference or an owned Row.
encode_feedback 🔒
Key the persist feedback by UpsertKey, record source statistics, and encode (UpsertKey, UpsertValue) as (UpsertKey, Row) Column chunks, the input both flavors’ feedback arrangements consume. Built with Pipeline downstream of an UpsertKey::hashed exchange, so the arrangement keeps that locality.
upsert_value_byte_len 🔒
Heap-size estimate for an emitted UpsertValue, used to drive give_fueled yielding on the output edge.

Type Aliases§

FeedbackChunk 🔒
One feedback-arrangement chunk: a sorted, consolidated run of updates, resident or spilled to the buffer pool. Both batcher chains and sealed spine batches are sequences of these, so the arrangement’s state pages out of RSS under the pool’s budget, and the drain reads it back through the bulk UnloadChunk surface: copy-out probes, no cursor borrows.
FeedbackSpine 🔒
The feedback arrangement’s trace: a funded spine of Rc-shared chunk batches. See mz_timely_util::funded_spine.
FeedbackUpdate 🔒
One persist-feedback update: a key, its current value row, the time, and an additive count.