()
| 178 | |
| 179 | #[test] |
| 180 | fn dedup_last_write_wins() { |
| 181 | let mut buf = O3Buffer::new(100); |
| 182 | buf.insert(make_row(100, 1, 0)); |
| 183 | buf.insert(make_row(100, 1, 0)); // duplicate |
| 184 | buf.insert(make_row(200, 1, 0)); |
| 185 | assert_eq!(buf.len(), 3); |
| 186 | |
| 187 | buf.dedup(); |
| 188 | assert_eq!(buf.len(), 2); |
| 189 | } |
| 190 | |
| 191 | #[test] |
| 192 | fn target_partition_count() { |