(engine: &mut ArrayEngine, x: i64, v: i64, sys_ms: i64, lsn: u64)
| 323 | } |
| 324 | |
| 325 | fn put_cell(engine: &mut ArrayEngine, x: i64, v: i64, sys_ms: i64, lsn: u64) { |
| 326 | engine |
| 327 | .put_cells( |
| 328 | &test_aid(), |
| 329 | vec![ArrayPutCell { |
| 330 | coord: vec![CoordValue::Int64(x)], |
| 331 | attrs: vec![CellValue::Int64(v)], |
| 332 | surrogate: Surrogate::ZERO, |
| 333 | system_from_ms: sys_ms, |
| 334 | valid_from_ms: 0, |
| 335 | valid_until_ms: i64::MAX, |
| 336 | }], |
| 337 | lsn, |
| 338 | ) |
| 339 | .unwrap(); |
| 340 | } |
| 341 | |
| 342 | fn run_purge(e: &mut ArrayEngine, horizon_ms: i64) -> u64 { |
| 343 | let schema = test_schema(); |