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.

For standalone use without SET/RESET support. When used via [SQLContext], the handler creates the provider internally with shared dynamic options.

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 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.