Struct MemoryCatalogProvider 

pub struct MemoryCatalogProvider {
    schemas: DashMap<String, Arc<dyn SchemaProvider>>,
}

Simple in-memory implementation of a catalog.

Fields

schemas: DashMap<String, Arc<dyn SchemaProvider>>

Implementations

impl MemoryCatalogProvider

pub fn new() -> MemoryCatalogProvider

Instantiates a new MemoryCatalogProvider with an empty collection of schemas.

Trait Implementations

impl CatalogProvider for MemoryCatalogProvider

fn as_any(&self) -> &(dyn Any + 'static)

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 MemoryCatalogProvider

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

Formats the value using the given formatter.

impl Default for MemoryCatalogProvider

fn default() -> MemoryCatalogProvider

Returns the “default value” for a type.