4.2. Merging Streams🔗

Tables computed with the same hash bank merge by adding corresponding counters. Cslib.DataStructure.CountMin.run_append identifies this operation with processing the concatenated streams. The equality concerns the whole table; taking minima does not make point estimates additive.

example : merge (run exampleHash [(0, 2)])
    (run exampleHash [(1, 3), (2, 5)]) = run exampleHash exampleStream := by⊢ merge (run exampleHash [(0, 2)]) (run exampleHash [(1, 3), (2, 5)]) = run exampleHash exampleStream
  decideAll goals completed! 🐙

For online processing, Cslib.DataStructure.CountMin.run_append_singleton identifies appending one event to the input with applying one update to the current table.