()
| 53 | |
| 54 | #[test] |
| 55 | fn compaction_merges_l0_segments() { |
| 56 | let dir = TempDir::new().unwrap(); |
| 57 | let mut cfg = ArrayEngineConfig::new(dir.path().to_path_buf()); |
| 58 | cfg.flush_cell_threshold = 1; |
| 59 | let mut e = ArrayEngine::new(cfg).unwrap(); |
| 60 | e.open_array(aid(), schema(), 0x1).unwrap(); |
| 61 | for i in 0..4 { |
| 62 | put_one(&mut e, i, 0, i, (i as u64) + 1); |
| 63 | } |
| 64 | assert_eq!(e.store(&aid()).unwrap().manifest().segments.len(), 4); |
| 65 | let merged = e.maybe_compact(&aid(), None, 0).unwrap(); |
| 66 | assert!(merged); |
| 67 | let m = e.store(&aid()).unwrap().manifest(); |
| 68 | assert_eq!(m.segments.len(), 1); |
| 69 | assert_eq!(m.segments[0].level, 1); |
| 70 | } |
| 71 | } |
nothing calls this directly
no test coverage detected