pub(crate) fn key_persist_feedback<'scope, T>(
ok: VecCollection<'scope, T, Row, Diff>,
err: VecCollection<'scope, T, DataflowError, Diff>,
key_indices: Vec<usize>,
) -> VecCollection<'scope, T, (UpsertKey, UpsertValue), Diff>where
T: Timestamp,Expand description
Keys this operator’s previous output, read back from persist, for retraction.
Only UpsertError survives the error side. It is the one error this operator can have
written, and therefore the one it can retract; anything else entered the shard from
elsewhere and is not ours to take back.