Struct DataFusionCatalogBridge 

pub struct DataFusionCatalogBridge { /* private fields */ }

Bridges a Krishiv InMemoryCatalog into a DataFusion CatalogProvider.

The bridge exposes a single schema named "public" that mirrors the tables registered in the underlying InMemoryCatalog.

Implementations

impl DataFusionCatalogBridge

pub fn new(catalog: Arc<RwLock<InMemoryCatalog>>) -> Self

Create a bridge from an InMemoryCatalog shared reference.

pub fn invalidate(&self, name: &str)

Invalidate the MemTable cache for name, forcing the next table() call to rebuild the cached MemTable from the catalog’s batch store. Call this after register_table_with_batches mutates the underlying catalog so the bridge does not serve a stale MemTable referencing the previous batch payload.

The DashMap cache is per-bridge and survives across DataFusion table() calls; without this invalidation hook a second register_table_with_batches for the same name would not be visible to the DataFusion query plan.

Trait Implementations

impl CatalogProvider for DataFusionCatalogBridge

fn as_any(&self) -> &dyn Any

Returns the catalog provider as Any so that it can be downcast to a specific implementation.

fn schema_names(&self) -> Vec<String>

Retrieves the list of available schema names in this catalog.

fn schema(&self, name: &str) -> Option<Arc<dyn SchemaProvider>>

Retrieves a specific schema from the catalog by name, provided it exists.

fn register_schema( &self, name: &str, schema: Arc<dyn SchemaProvider>, ) -> Result<Option<Arc<dyn SchemaProvider>>, DataFusionError>

Adds a new schema to this catalog.

fn deregister_schema( &self, _name: &str, _cascade: bool, ) -> Result<Option<Arc<dyn SchemaProvider>>, DataFusionError>

Removes a schema from this catalog. Implementations of this method should return errors if the schema exists but cannot be dropped. For example, in DataFusion’s default in-memory catalog, MemoryCatalogProvider, a non-empty schema will only be successfully dropped when cascade is true. This is equivalent to how DROP SCHEMA works in PostgreSQL.

impl Debug for DataFusionCatalogBridge

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

Formats the value using the given formatter.