(
store: &mut ArrayStore,
cells: Vec<super::wal::ArrayDeleteCell>,
lsn: u64,
)
| 113 | } |
| 114 | |
| 115 | pub(crate) fn stamp_delete_cells( |
| 116 | store: &mut ArrayStore, |
| 117 | cells: Vec<super::wal::ArrayDeleteCell>, |
| 118 | lsn: u64, |
| 119 | ) -> ArrayEngineResult<()> { |
| 120 | let schema = store.schema().clone(); |
| 121 | for c in cells { |
| 122 | if c.erasure { |
| 123 | store |
| 124 | .memtable |
| 125 | .erase_cell(&schema, c.coord, c.system_from_ms, lsn)?; |
| 126 | } else { |
| 127 | store |
| 128 | .memtable |
| 129 | .delete_cell(&schema, c.coord, c.system_from_ms, lsn)?; |
| 130 | } |
| 131 | } |
| 132 | Ok(()) |
| 133 | } |
| 134 | |
| 135 | #[cfg(test)] |
| 136 | mod tests { |
no test coverage detected