Struct DataBackendSession 

pub struct DataBackendSession {
    pub chunk_size: usize,
    pub runtime: Handle,
    /* private fields */
}

Provides a DataFusion session for registering and querying catalog table sources.

Fields

chunk_size: usize

runtime: Handle

Implementations

impl DataBackendSession

pub fn new(chunk_size: usize) -> Self

Creates a new DataBackendSession instance.

pub fn register_object_store( &mut self, url: &Url, object_store: Arc<dyn ObjectStore>, )

Register an object store with the session context

pub fn register_storage_backend( &mut self, storage: &StorageBackend, ) -> Result<()>

Registers an OpenDAL-backed storage backend with the session context.

External catalog implementations can call this before adding native table providers or object-store-relative file paths to the session.

Errors

Returns an error if the storage URI cannot be converted into a DataFusion root URL.

pub fn register_table_provider( &mut self, table_name: &str, provider: Arc<dyn TableProvider>, ) -> Result<()>

Registers a table provider with the session context.

This supports non-Parquet table formats such as Delta Lake while keeping the Parquet registration path unchanged.

pub fn clear_registered_tables(&mut self)

Clears all registered tables.

This is useful when the underlying files have changed and we need to re-register tables with updated data.