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

Method object_store

datafusion/execution/src/runtime_env.rs:204–206  ·  view source on GitHub ↗

Retrieves a `ObjectStore` instance for a url by consulting the registry. See [`ObjectStoreRegistry::get_store`] for more details.

(&self, url: impl AsRef<Url>)

Source from the content-addressed store, hash-verified

202 /// registry. See [`ObjectStoreRegistry::get_store`] for more
203 /// details.
204 pub fn object_store(&self, url: impl AsRef<Url>) -> Result<Arc<dyn ObjectStore>> {
205 self.object_store_registry.get_store(url.as_ref())
206 }
207
208 /// Returns the current spilling progress
209 pub fn spilling_progress(&self) -> SpillingProgress {

Callers

nothing calls this directly

Calls 2

get_storeMethod · 0.45
as_refMethod · 0.45

Tested by

no test coverage detected