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

Method register_object_store

datafusion/core/src/execution/context/mod.rs:520–526  ·  view source on GitHub ↗

Registers an [`ObjectStore`] to be used with a specific URL prefix. See [`RuntimeEnv::register_object_store`] for more details. # Example: register a local object store for the "file://" URL prefix ``` # use std::sync::Arc; # use datafusion::prelude::SessionContext; # use datafusion_execution::object_store::ObjectStoreUrl; let object_store_url = ObjectStoreUrl::parse("file://").unwrap(); let obj

(
        &self,
        url: &Url,
        object_store: Arc<dyn ObjectStore>,
    )

Source from the content-addressed store, hash-verified

518 /// ctx.register_object_store(object_store_url.as_ref(), Arc::new(object_store));
519 /// ```
520 pub fn register_object_store(
521 &self,
522 url: &Url,
523 object_store: Arc<dyn ObjectStore>,
524 ) -> Option<Arc<dyn ObjectStore>> {
525 self.runtime_env().register_object_store(url, object_store)
526 }
527
528 /// Deregisters an [`ObjectStore`] associated with the specific URL prefix.
529 ///

Callers 15

setup_contextFunction · 0.45
create_planFunction · 0.45
test_with_storesFunction · 0.45
test_additional_storesFunction · 0.45
write_json_resultsFunction · 0.45
test_additional_storesFunction · 0.45
test_terminatorFunction · 0.45

Calls 1

runtime_envMethod · 0.45