Struct FileCatalog 

pub struct FileCatalog { /* private fields */ }

File-backed table catalog.

Operations are serialized across handles in this process and refresh CURRENT before every read or mutation. One active catalog mutator is still required across processes; distributed locking is intentionally outside this implementation.

Implementations

impl FileCatalog

pub fn open( config: &Config, catalog_config: FileCatalogConfig, ) -> CatalogResult<Self>

pub fn materialize_table( &self, db: Arc<Db>, identifier: &TableIdentifier, ) -> CatalogResult<Table>

Materialize the current catalog schema into one writable shard.

Calls for a shard must not run concurrently with other core schema updates.

impl FileCatalog

pub fn load_shard_schema_mapping( &self, identifier: &TableIdentifier, db_id: &str, catalog_schema_id: CatalogSchemaId, ) -> CatalogResult<ShardSchemaMapping>

Load the core schema id used for one table schema on a shard.

Trait Implementations

impl Catalog for FileCatalog

fn create_namespace(&self, namespace: Vec<String>) -> CatalogResult<()>

fn list_namespaces(&self) -> CatalogResult<Vec<Vec<String>>>

fn drop_namespace(&self, namespace: &[String]) -> CatalogResult<()>

fn create_table( &self, identifier: TableIdentifier, schema: TableSchema, ) -> CatalogResult<CatalogTable>

fn load_table( &self, identifier: &TableIdentifier, ) -> CatalogResult<CatalogTable>

fn load_table_schema( &self, identifier: &TableIdentifier, catalog_schema_id: CatalogSchemaId, ) -> CatalogResult<TableSchema>

fn evolve_schema( &self, identifier: &TableIdentifier, changes: Vec<SchemaChange>, ) -> CatalogResult<CatalogTable>

fn list_tables( &self, namespace: &[String], ) -> CatalogResult<Vec<TableIdentifier>>

fn table_exists(&self, identifier: &TableIdentifier) -> CatalogResult<bool>

fn rename_table( &self, identifier: &TableIdentifier, new_name: String, ) -> CatalogResult<CatalogTable>

fn drop_table(&self, identifier: &TableIdentifier) -> CatalogResult<()>