(&self, url: &Url)
| 253 | } |
| 254 | |
| 255 | fn get_store(&self, url: &Url) -> Result<Arc<dyn ObjectStore>> { |
| 256 | let s = get_url_key(url); |
| 257 | self.object_stores |
| 258 | .get(&s) |
| 259 | .map(|o| Arc::clone(o.value())) |
| 260 | .ok_or_else(|| { |
| 261 | internal_datafusion_err!("No suitable object store found for {url}. See `RuntimeEnv::register_object_store`") |
| 262 | }) |
| 263 | } |
| 264 | } |
| 265 | |
| 266 | /// Get the key of a url for object store registration. |