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

Method get_store

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

Source from the content-addressed store, hash-verified

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.

Callers 5

test_get_store_hdfsFunction · 0.45
test_get_store_s3Function · 0.45
test_get_store_fileFunction · 0.45
test_get_store_localFunction · 0.45
object_storeMethod · 0.45

Calls 4

get_url_keyFunction · 0.85
mapMethod · 0.45
getMethod · 0.45
valueMethod · 0.45

Tested by 4

test_get_store_hdfsFunction · 0.36
test_get_store_s3Function · 0.36
test_get_store_fileFunction · 0.36
test_get_store_localFunction · 0.36