Struct GraphCatalog 

pub struct GraphCatalog { /* private fields */ }

DataFusion CatalogProvider for a GraphForge project directory.

Exposes topology, edge, and property tables under the "graph" schema. Construct via GraphCatalog::open.

Implementations

impl GraphCatalog

pub fn open( dir: &Path, ontology: Option<&OntologyHandle>, runtime_catalog: &RuntimeCatalog, ) -> Result<Self, DataFusionError>

Open a GraphForge project directory as a DataFusion catalog.

• dir: project root (contains topology/, properties/, etc.)
• ontology: compiled ontology, or None in exploratory mode
• runtime_catalog: runtime type catalog for exploratory mode

Errors

Propagates I/O errors encountered while registering tables.

pub fn prop_names(&self) -> &HashMap<u32, String>

Reverse map PropId.0 → property name (ontology + runtime catalog), used by the relational lowering layer to resolve PropertyAccess.

pub fn rel_names(&self) -> &HashMap<u32, String>

Reverse map RuntimeTypeId.0 → relation-type name from the runtime catalog. The relational lowerer tags these keys before merging them with ontology TypeIds so the two zero-based ID spaces cannot collide.

pub fn label_names(&self) -> &HashMap<u32, String>

Reverse map TypeId.0 → entity-type (node label) name, from the runtime catalog. Used by the relational lowering layer to render a node value’s label for an unlabelled match — including in exploratory mode, where the ontology map is empty (#889).

Trait Implementations

impl CatalogProvider for GraphCatalog

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>, ) -> 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 GraphCatalog

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

Formats the value using the given formatter.