Function mz_stash::consolidate_updates
source · pub(crate) fn consolidate_updates<I>(
rows: I
) -> impl Iterator<Item = ((Value, Value), Timestamp, Diff)>where
I: IntoIterator<Item = ((Value, Value), Timestamp, Diff)>,
Expand description
Helper function to consolidate serde_json::Value
updates. Value
doesn’t
implement Ord
which is required by consolidate_updates
, so we must
serialize and deserialize through bytes.