Function mz_compute::logging::compute::sum_batch_diffs

fn sum_batch_diffs<B>(batch: &B) -> Diff
where
    for<'a> B: BatchReader<DiffGat<'a> = &'a Diff>,

Return the sum of all diffs within the given batch.

Note that this operation can be expensive: Its runtime is O(N) with N being the number of unique (key, value, time) tuples. We only use it on error streams, which are expected to contain only a small number of records, so this doesn’t matter much. But avoid using it when batches might become large.