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_name: Option<String>, catalog: Arc<dyn Catalog>, dynamic_options: Arc<RwLock<HashMap<String, String>>>, blob_reader_registry: BlobReaderRegistry, session_state: Option<Arc<dyn Fn() -> Option<SessionState> + Send + Sync>>, ) -> Self

Creates a new PaimonCatalogProvider.

pub fn with_schema_force_view_types(self, schema_force_view_types: bool) -> Self

Configure whether table schemas use Arrow view types when available.

Disable this for consumers that cannot operate on Arrow view arrays. This changes the schema exposed to DataFusion, so query operators above the table scan will use the classic Arrow types as well.

impl PaimonCatalogProvider

pub fn register_temp_table( &self, database: &str, table_name: &str, table: Arc<dyn TableProvider>, ) -> DFResult<()>

Registers a temporary table or view in the specified database. Creates the database if it does not exist.

Returns an error if a temp table with the same name already exists in the same database. Logs a warning if the name shadows a real Paimon table.

pub fn deregister_temp_table( &self, database: &str, table_name: &str, ) -> DFResult<Option<Arc<dyn TableProvider>>>

Deregisters a temporary table or view from the specified database.

pub fn has_temp_table_database(&self, name: &str) -> bool

Returns whether a temp table database exists with the given name.

pub fn temp_table_exist(&self, database: &str, table_name: &str) -> bool

Returns whether a temp table with the given name exists in the specified database.

Trait Implementations

impl CatalogProvider for PaimonCatalogProvider

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.