Struct SchemaCatalog

pub struct SchemaCatalog {

    id: u32,
    pub name: String,
    pub database_id: u32,
    table_by_name: HashMap<String, Arc<TableCatalog>>,
    table_by_id: HashMap<TableId, Arc<TableCatalog>>,
    source_by_name: HashMap<String, Arc<SourceCatalog>>,
    source_by_id: HashMap<u32, Arc<SourceCatalog>>,
    sink_by_name: HashMap<String, Arc<SinkCatalog>>,
    sink_by_id: HashMap<u32, Arc<SinkCatalog>>,
    subscription_by_name: HashMap<String, Arc<SubscriptionCatalog>>,
    subscription_by_id: HashMap<u32, Arc<SubscriptionCatalog>>,
    index_by_name: HashMap<String, Arc<IndexCatalog>>,
    index_by_id: HashMap<IndexId, Arc<IndexCatalog>>,
    indexes_by_table_id: HashMap<TableId, Vec<Arc<IndexCatalog>>>,
    view_by_name: HashMap<String, Arc<ViewCatalog>>,
    view_by_id: HashMap<u32, Arc<ViewCatalog>>,
    function_registry: FunctionRegistry,
    function_by_name: HashMap<String, HashMap<Vec<DataType>, Arc<FunctionCatalog>>>,
    function_by_id: HashMap<FunctionId, Arc<FunctionCatalog>>,
    connection_by_name: HashMap<String, Arc<ConnectionCatalog>>,
    connection_by_id: HashMap<u32, Arc<ConnectionCatalog>>,
    secret_by_name: HashMap<String, Arc<SecretCatalog>>,
    secret_by_id: HashMap<SecretId, Arc<SecretCatalog>>,
    _secret_source_ref: HashMap<SecretId, Vec<u32>>,
    _secret_sink_ref: HashMap<SecretId, Vec<u32>>,
    connection_source_ref: HashMap<u32, Vec<u32>>,
    connection_sink_ref: HashMap<u32, Vec<u32>>,
    system_table_by_name: HashMap<String, Arc<SystemTableCatalog>>,
    pub owner: u32,
}

Fields

id: u32

name: String

database_id: u32

table_by_name: HashMap<String, Arc<TableCatalog>>

table_by_id: HashMap<TableId, Arc<TableCatalog>>

source_by_name: HashMap<String, Arc<SourceCatalog>>

source_by_id: HashMap<u32, Arc<SourceCatalog>>

sink_by_name: HashMap<String, Arc<SinkCatalog>>

sink_by_id: HashMap<u32, Arc<SinkCatalog>>

subscription_by_name: HashMap<String, Arc<SubscriptionCatalog>>

subscription_by_id: HashMap<u32, Arc<SubscriptionCatalog>>

index_by_name: HashMap<String, Arc<IndexCatalog>>

index_by_id: HashMap<IndexId, Arc<IndexCatalog>>

indexes_by_table_id: HashMap<TableId, Vec<Arc<IndexCatalog>>>

view_by_name: HashMap<String, Arc<ViewCatalog>>

view_by_id: HashMap<u32, Arc<ViewCatalog>>

function_registry: FunctionRegistry

function_by_name: HashMap<String, HashMap<Vec<DataType>, Arc<FunctionCatalog>>>

function_by_id: HashMap<FunctionId, Arc<FunctionCatalog>>

connection_by_name: HashMap<String, Arc<ConnectionCatalog>>

connection_by_id: HashMap<u32, Arc<ConnectionCatalog>>

secret_by_name: HashMap<String, Arc<SecretCatalog>>

secret_by_id: HashMap<SecretId, Arc<SecretCatalog>>

_secret_source_ref: HashMap<SecretId, Vec<u32>>

_secret_sink_ref: HashMap<SecretId, Vec<u32>>

connection_source_ref: HashMap<u32, Vec<u32>>

connection_sink_ref: HashMap<u32, Vec<u32>>

system_table_by_name: HashMap<String, Arc<SystemTableCatalog>>

owner: u32

Implementations

impl SchemaCatalog

pub fn create_table(&mut self, prost: &PbTable) -> Arc<TableCatalog>

pub fn create_sys_table(&mut self, sys_table: Arc<SystemTableCatalog>)

pub fn create_sys_view(&mut self, sys_view: Arc<ViewCatalog>)

pub fn update_table(&mut self, prost: &PbTable) -> Arc<TableCatalog>

pub fn update_index(&mut self, prost: &PbIndex)

pub fn drop_table(&mut self, id: TableId)

pub fn create_index(&mut self, prost: &PbIndex)

pub fn drop_index(&mut self, id: IndexId)

pub fn create_source(&mut self, prost: &PbSource)

pub fn drop_source(&mut self, id: u32)

pub fn update_source(&mut self, prost: &PbSource)

pub fn create_sink(&mut self, prost: &PbSink)

pub fn drop_sink(&mut self, id: u32)

pub fn update_sink(&mut self, prost: &PbSink)

pub fn create_subscription(&mut self, prost: &PbSubscription)

pub fn drop_subscription(&mut self, id: u32)

pub fn update_subscription(&mut self, prost: &PbSubscription)

pub fn create_view(&mut self, prost: &PbView)

pub fn drop_view(&mut self, id: u32)

pub fn update_view(&mut self, prost: &PbView)

pub fn get_func_sign(func: &FunctionCatalog) -> FuncSign

pub fn create_function(&mut self, prost: &PbFunction)

pub fn drop_function(&mut self, id: FunctionId)

pub fn update_function(&mut self, prost: &PbFunction)

pub fn create_connection(&mut self, prost: &PbConnection)

pub fn update_connection(&mut self, prost: &PbConnection)

pub fn drop_connection(&mut self, connection_id: u32)

pub fn create_secret(&mut self, prost: &PbSecret)

pub fn update_secret(&mut self, prost: &PbSecret)

pub fn drop_secret(&mut self, secret_id: SecretId)

pub fn iter_all(&self) -> impl Iterator<Item = &Arc<TableCatalog>>

pub fn iter_table(&self) -> impl Iterator<Item = &Arc<TableCatalog>>

pub fn iter_internal_table(&self) -> impl Iterator<Item = &Arc<TableCatalog>>

pub fn iter_valid_table(&self) -> impl Iterator<Item = &Arc<TableCatalog>>

pub fn iter_all_mvs(&self) -> impl Iterator<Item = &Arc<TableCatalog>>

Iterate all materialized views, excluding the indices.

pub fn iter_created_mvs(&self) -> impl Iterator<Item = &Arc<TableCatalog>>

Iterate created materialized views, excluding the indices.

pub fn iter_index(&self) -> impl Iterator<Item = &Arc<IndexCatalog>>

Iterate all indices

pub fn iter_source(&self) -> impl Iterator<Item = &Arc<SourceCatalog>>

Iterate all sources

pub fn iter_sink(&self) -> impl Iterator<Item = &Arc<SinkCatalog>>

pub fn iter_subscription( &self, ) -> impl Iterator<Item = &Arc<SubscriptionCatalog>>

pub fn iter_view(&self) -> impl Iterator<Item = &Arc<ViewCatalog>>

pub fn iter_function(&self) -> impl Iterator<Item = &Arc<FunctionCatalog>>

pub fn iter_connections(&self) -> impl Iterator<Item = &Arc<ConnectionCatalog>>

pub fn iter_secret(&self) -> impl Iterator<Item = &Arc<SecretCatalog>>

pub fn iter_system_tables( &self, ) -> impl Iterator<Item = &Arc<SystemTableCatalog>>

pub fn get_table_by_name(&self, table_name: &str) -> Option<&Arc<TableCatalog>>

pub fn get_created_table_by_name( &self, table_name: &str, ) -> Option<&Arc<TableCatalog>>

pub fn get_table_by_id(&self, table_id: &TableId) -> Option<&Arc<TableCatalog>>

pub fn get_created_table_by_id( &self, table_id: &TableId, ) -> Option<&Arc<TableCatalog>>

pub fn get_view_by_name(&self, view_name: &str) -> Option<&Arc<ViewCatalog>>

pub fn get_view_by_id(&self, view_id: &u32) -> Option<&Arc<ViewCatalog>>

pub fn get_source_by_name( &self, source_name: &str, ) -> Option<&Arc<SourceCatalog>>

pub fn get_source_by_id(&self, source_id: &u32) -> Option<&Arc<SourceCatalog>>

pub fn get_sink_by_name(&self, sink_name: &str) -> Option<&Arc<SinkCatalog>>

pub fn get_sink_by_id(&self, sink_id: &u32) -> Option<&Arc<SinkCatalog>>

pub fn get_subscription_by_name( &self, subscription_name: &str, ) -> Option<&Arc<SubscriptionCatalog>>

pub fn get_subscription_by_id( &self, subscription_id: &u32, ) -> Option<&Arc<SubscriptionCatalog>>

pub fn get_index_by_name(&self, index_name: &str) -> Option<&Arc<IndexCatalog>>

pub fn get_index_by_id(&self, index_id: &IndexId) -> Option<&Arc<IndexCatalog>>

pub fn get_indexes_by_table_id( &self, table_id: &TableId, ) -> Vec<Arc<IndexCatalog>>

pub fn get_system_table_by_name( &self, table_name: &str, ) -> Option<&Arc<SystemTableCatalog>>

pub fn get_table_name_by_id(&self, table_id: TableId) -> Option<String>

pub fn get_function_by_id( &self, function_id: FunctionId, ) -> Option<&Arc<FunctionCatalog>>

pub fn get_function_by_name_inputs( &self, name: &str, inputs: &mut [ExprImpl], ) -> Option<&Arc<FunctionCatalog>>

pub fn get_function_by_name_args( &self, name: &str, args: &[DataType], ) -> Option<&Arc<FunctionCatalog>>

pub fn get_functions_by_name( &self, name: &str, ) -> Option<Vec<&Arc<FunctionCatalog>>>

pub fn get_connection_by_id( &self, connection_id: &u32, ) -> Option<&Arc<ConnectionCatalog>>

pub fn get_connection_by_name( &self, connection_name: &str, ) -> Option<&Arc<ConnectionCatalog>>

pub fn get_secret_by_name( &self, secret_name: &str, ) -> Option<&Arc<SecretCatalog>>

pub fn get_secret_by_id( &self, secret_id: &SecretId, ) -> Option<&Arc<SecretCatalog>>

pub fn get_source_ids_by_connection( &self, connection_id: u32, ) -> Option<Vec<u32>>

get all sources referencing the connection

pub fn get_sink_ids_by_connection(&self, connection_id: u32) -> Option<Vec<u32>>

get all sinks referencing the connection

pub fn get_grant_object_by_oid(&self, oid: u32) -> Option<Object>

pub fn id(&self) -> u32

pub fn database_id(&self) -> u32

pub fn name(&self) -> String

Trait Implementations

impl Clone for SchemaCatalog

fn clone(&self) -> SchemaCatalog

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SchemaCatalog

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

Formats the value using the given formatter.

impl From<&Schema> for SchemaCatalog

fn from(schema: &PbSchema) -> Self

Converts to this type from the input type.

impl OwnedByUserCatalog for SchemaCatalog

fn owner(&self) -> u32

Returns the owner of the catalog.