(&self, url: &Url)
| 242 | } |
| 243 | |
| 244 | fn deregister_store(&self, url: &Url) -> Result<Arc<dyn ObjectStore>> { |
| 245 | let s = get_url_key(url); |
| 246 | let (_, object_store) = self.object_stores |
| 247 | .remove(&s) |
| 248 | .ok_or_else(|| { |
| 249 | internal_datafusion_err!("Failed to deregister object store. No suitable object store found for {url}. See `RuntimeEnv::register_object_store`") |
| 250 | })?; |
| 251 | |
| 252 | Ok(object_store) |
| 253 | } |
| 254 | |
| 255 | fn get_store(&self, url: &Url) -> Result<Arc<dyn ObjectStore>> { |
| 256 | let s = get_url_key(url); |
no test coverage detected