(
&self,
cmd: &CreateExternalTable,
)
| 1411 | } |
| 1412 | |
| 1413 | async fn create_custom_table( |
| 1414 | &self, |
| 1415 | cmd: &CreateExternalTable, |
| 1416 | ) -> Result<Arc<dyn TableProvider>> { |
| 1417 | let state = self.state.read().clone(); |
| 1418 | let file_type = cmd.file_type.to_uppercase(); |
| 1419 | let factory = |
| 1420 | state |
| 1421 | .table_factories() |
| 1422 | .get(file_type.as_str()) |
| 1423 | .ok_or_else(|| { |
| 1424 | exec_datafusion_err!("Unable to find factory for {}", cmd.file_type) |
| 1425 | })?; |
| 1426 | let table = (*factory).create(&state, cmd).await?; |
| 1427 | Ok(table) |
| 1428 | } |
| 1429 | |
| 1430 | async fn find_and_deregister( |
| 1431 | &self, |
no test coverage detected