Struct RedapCatalogProvider 

pub struct RedapCatalogProvider { /* private fields */ }

DataFusion catalog provider for interacting with Rerun gRPC services.

Tables are stored on the server in a flat namespace with a string representation of the catalog, schema, and table delimited by a period. This matches typical SQL style naming conventions. It the catalog or schema is not specified, it will be assumed to use the defaults. For example a table stored with table named my_table will be stored within the datafusion catalog and public schema. If a table is specified with more than three levels, it will also be stored in the default catalog and schema. This matches how DataFusion will store such table names.

Implementations

impl RedapCatalogProvider

pub fn new( name: Option<&str>, client: ConnectionClient, runtime: RuntimeHandle, ) -> Self

Trait Implementations

impl CatalogProvider for RedapCatalogProvider

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 RedapCatalogProvider

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

Formats the value using the given formatter.