Skip to content

Commit fb8d188

Browse files
committed
remove durable_deletes
1 parent 164b761 commit fb8d188

File tree

2 files changed

+1
-13
lines changed

2 files changed

+1
-13
lines changed

crates/core/src/db/relational_db.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -840,7 +840,7 @@ impl RelationalDB {
840840
let truncates: IntSet<TableId> = tx_data.truncates().collect();
841841

842842
let deletes: Box<_> = tx_data
843-
.durable_deletes()
843+
.deletes()
844844
.filter(|(table_id, _)| is_not_ephemeral_table(table_id))
845845
.map(|(table_id, rowdata)| Ops {
846846
table_id: *table_id,
@@ -2539,7 +2539,6 @@ mod tests {
25392539
.collect()
25402540
}
25412541

2542-
25432542
#[test]
25442543
fn test_view_tables_are_ephemeral() -> ResultTest<()> {
25452544
let stdb = TestDB::durable()?;

crates/datastore/src/traits.rs

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -281,17 +281,6 @@ impl TxData {
281281
self.deletes.iter()
282282
}
283283

284-
/// Obtain an iterator over the deleted rows per table,
285-
/// excluding ephemeral tables.
286-
pub fn durable_deletes(&self) -> impl Iterator<Item = (&TableId, &Arc<[ProductValue]>)> + '_ {
287-
self.deletes.iter().filter(move |(table_id, _)| {
288-
!self
289-
.ephemeral_tables
290-
.as_ref()
291-
.is_some_and(|etables| etables.contains(*table_id))
292-
})
293-
}
294-
295284
/// Get the `i`th deleted row for `table_id` if it exists
296285
pub fn get_ith_delete(&self, table_id: TableId, i: usize) -> Option<&ProductValue> {
297286
self.deletes.get(&table_id).and_then(|rows| rows.get(i))

0 commit comments

Comments
 (0)