Function open_engine

nodedb/tests/bitemporal_array_temporal_purge.rs:57–63

Open an engine with `flush_cell_threshold = 1` so every `put_cells` call lands in a fresh segment. This makes it easy to produce multiple system-time versions of the same coordinate in separate segments, which exercises the cross-segment retention logic in `plan.rs`.

(dir: &TempDir)

/// system-time versions of the same coordinate in separate segments,
/// which exercises the cross-segment retention logic in `plan.rs`.
fn open_engine(dir: &TempDir) -> ArrayEngine {
    let mut cfg = ArrayEngineConfig::new(dir.path().to_path_buf());
    cfg.flush_cell_threshold = 1;
    let mut e = ArrayEngine::new(cfg).unwrap();
    e.open_array(aid(), schema(), SCHEMA_HASH).unwrap();
    e
}

fn put(e: &mut ArrayEngine, x: i64, v: i64, sys_ms: i64, lsn: u64) {
    e.put_cells(