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

Method register_store

datafusion/execution/src/object_store.rs:235–242  ·  view source on GitHub ↗
(
        &self,
        url: &Url,
        store: Arc<dyn ObjectStore>,
    )

Source from the content-addressed store, hash-verified

233/// - `hdfs://host:port/path` will return a store registered with `hdfs://host:port` if any
234impl 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);

Callers 4

test_get_store_hdfsFunction · 0.45
test_get_store_s3Function · 0.45
build_ctxFunction · 0.45
register_object_storeMethod · 0.45

Calls 2

get_url_keyFunction · 0.85
insertMethod · 0.45

Tested by 2

test_get_store_hdfsFunction · 0.36
test_get_store_s3Function · 0.36