(rows: usize)
| 21 | } |
| 22 | |
| 23 | fn write_segment(rows: usize) -> Vec<u8> { |
| 24 | let schema = test_schema(); |
| 25 | let mut mt = ColumnarMemtable::new(&schema); |
| 26 | for i in 0..rows { |
| 27 | mt.append_row(&[ |
| 28 | Value::Integer(i as i64), |
| 29 | Value::String(format!("user_{i}")), |
| 30 | if i % 3 == 0 { |
| 31 | Value::Null |
| 32 | } else { |
| 33 | Value::Float(i as f64 * 0.5) |
| 34 | }, |
| 35 | ]) |
| 36 | .expect("append"); |
| 37 | } |
| 38 | let (schema, columns, row_count) = mt.drain(); |
| 39 | SegmentWriter::plain() |
| 40 | .write_segment(&schema, &columns, row_count, None) |
| 41 | .expect("write") |
| 42 | } |
| 43 | |
| 44 | #[test] |
| 45 | fn compact_removes_deleted_rows() { |
no test coverage detected