(
&self,
url: &Url,
store: Arc<dyn ObjectStore>,
)
| 233 | /// - `hdfs://host:port/path` will return a store registered with `hdfs://host:port` if any |
| 234 | impl ObjectStoreRegistry for DefaultObjectStoreRegistry { |
| 235 | fn register_store( |
| 236 | &self, |
| 237 | url: &Url, |
| 238 | store: Arc<dyn ObjectStore>, |
| 239 | ) -> Option<Arc<dyn ObjectStore>> { |
| 240 | let s = get_url_key(url); |
| 241 | self.object_stores.insert(s, store) |
| 242 | } |
| 243 | |
| 244 | fn deregister_store(&self, url: &Url) -> Result<Arc<dyn ObjectStore>> { |
| 245 | let s = get_url_key(url); |