Dedup by (series_id, timestamp) — last-write-wins. Call before merge to handle retries/replays.
(&mut self)
| 82 | /// |
| 83 | /// Call before merge to handle retries/replays. |
| 84 | pub fn dedup(&mut self) { |
| 85 | self.ensure_sorted(); |
| 86 | self.rows |
| 87 | .dedup_by(|a, b| a.series_id == b.series_id && a.timestamp_ms == b.timestamp_ms); |
| 88 | } |
| 89 | |
| 90 | fn ensure_sorted(&mut self) { |
| 91 | if !self.sorted { |