(
&self,
table_ref: &Option<TableReference>,
table_type: TableType,
)
| 1455 | } |
| 1456 | |
| 1457 | fn invalidate_caches( |
| 1458 | &self, |
| 1459 | table_ref: &Option<TableReference>, |
| 1460 | table_type: TableType, |
| 1461 | ) -> Result<()> { |
| 1462 | if table_type == TableType::Base { |
| 1463 | if let Some(lfc) = self.runtime_env().cache_manager.get_list_files_cache() { |
| 1464 | lfc.drop_table_entries(table_ref)?; |
| 1465 | } |
| 1466 | if let Some(fsc) = self.runtime_env().cache_manager.get_file_statistic_cache() |
| 1467 | { |
| 1468 | fsc.drop_table_entries(table_ref)?; |
| 1469 | } |
| 1470 | } |
| 1471 | Ok(()) |
| 1472 | } |
| 1473 | |
| 1474 | async fn create_function(&self, stmt: CreateFunction) -> Result<DataFrame> { |
| 1475 | let function = { |
no test coverage detected