(
&self,
table_ref: &Option<TableReference>,
)
| 380 | } |
| 381 | |
| 382 | fn drop_table_entries( |
| 383 | &self, |
| 384 | table_ref: &Option<TableReference>, |
| 385 | ) -> datafusion_common::Result<()> { |
| 386 | let mut state = self.state.lock().unwrap(); |
| 387 | let mut table_paths = vec![]; |
| 388 | for (path, _) in state.lru_queue.list_entries() { |
| 389 | if path.table == *table_ref { |
| 390 | table_paths.push(path.clone()); |
| 391 | } |
| 392 | } |
| 393 | for path in table_paths { |
| 394 | state.remove(&path); |
| 395 | } |
| 396 | Ok(()) |
| 397 | } |
| 398 | } |
| 399 | |
| 400 | #[cfg(test)] |