Struct datafusion_execution::object_store::DefaultObjectStoreRegistry

pub struct DefaultObjectStoreRegistry { /* private fields */ }

The default ObjectStoreRegistry

Implementations

impl DefaultObjectStoreRegistry

pub fn new() -> Self

This will register LocalFileSystem to handle file:// paths

Trait Implementations

impl Debug for DefaultObjectStoreRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DefaultObjectStoreRegistry

fn default() -> Self

Returns the “default value” for a type.

impl ObjectStoreRegistry for DefaultObjectStoreRegistry

Stores are registered based on the scheme, host and port of the provided URL with a LocalFileSystem::new automatically registered for file://

For example:

• file:///my_path will return the default LocalFS store
• s3://bucket/path will return a store registered with s3://bucket if any
• hdfs://host:port/path will return a store registered with hdfs://host:port if any

fn register_store( &self, url: &Url, store: Arc<dyn ObjectStore> ) -> Option<Arc<dyn ObjectStore>>

If a store with the same key existed before, it is replaced and returned

fn get_store(&self, url: &Url) -> Result<Arc<dyn ObjectStore>>

Get a suitable store for the provided URL. For example: