Method materialise

nodedb/src/engine/array/memtable/tile_buffer.rs:135–170

Replay buffered entries into a fresh `SparseTile`. Live entries produce [`RowKind::Live`] rows with full payload. Sentinel entries (tombstone / GDPR erasure) are persisted as [`RowKind::Tombstone`] / [`RowKind::GdprErased`] rows so they survive the flush → segment round-trip. Compaction's retention policy is the only path permitted to drop them.

(&self, schema: &ArraySchema)

    /// survive the flush → segment round-trip. Compaction's retention
    /// policy is the only path permitted to drop them.
    pub fn materialise(&self, schema: &ArraySchema) -> ArrayResult<SparseTile> {
        let mut b = SparseTileBuilder::new(schema);
        for (coord_key, bytes) in &self.entries {
            let coord = Self::decode_coord(coord_key)?;
            if is_cell_tombstone(bytes) {
                b.push_row(SparseRow {
                    coord: &coord,
                    attrs: &[],
                    surrogate: Surrogate::ZERO,
                    valid_from_ms: 0,
                    valid_until_ms: OPEN_UPPER,
                    kind: RowKind::Tombstone,
                })?;
            } else if is_cell_gdpr_erasure(bytes) {
                b.push_row(SparseRow {
                    coord: &coord,
                    attrs: &[],
                    surrogate: Surrogate::ZERO,
                    valid_from_ms: 0,
                    valid_until_ms: OPEN_UPPER,
                    kind: RowKind::GdprErased,
                })?;
            } else {
                let payload = CellPayload::decode(bytes)?;
                b.push_row(SparseRow {
                    coord: &coord,
                    attrs: &payload.attrs,
                    surrogate: payload.surrogate,
                    valid_from_ms: payload.valid_from_ms,
                    valid_until_ms: payload.valid_until_ms,
                    kind: RowKind::Live,
                })?;
            }
        }
        Ok(b.build())
    }
}

#[derive(Debug, Default)]