MCPcopy Create free account
hub / github.com/apache/datafusion / deregister_store

Method deregister_store

datafusion/execution/src/object_store.rs:244–253  ·  view source on GitHub ↗
(&self, url: &Url)

Source from the content-addressed store, hash-verified

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);

Callers 1

Calls 2

get_url_keyFunction · 0.85
removeMethod · 0.45

Tested by

no test coverage detected