Struct PaimonCatalogProvider 

pub struct PaimonCatalogProvider { /* private fields */ }

Provides an interface to manage and access multiple schemas (databases) within a Paimon Catalog.

This provider uses lazy loading - databases and tables are fetched on-demand from the catalog, ensuring data is always fresh.

Implementations

impl PaimonCatalogProvider

pub fn new(catalog: Arc<dyn Catalog>) -> Self

Creates a new PaimonCatalogProvider.

All data is loaded lazily when accessed.

Trait Implementations

impl CatalogProvider for PaimonCatalogProvider

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>, ) -> DFResult<Option<Arc<dyn SchemaProvider>>>

Adds a new schema to this catalog.

fn deregister_schema( &self, name: &str, cascade: bool, ) -> DFResult<Option<Arc<dyn SchemaProvider>>>

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 PaimonCatalogProvider

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

Formats the value using the given formatter.