Struct TableMetadataManager

pub struct TableMetadataManager {
    table_name_manager: TableNameManager,
    table_info_manager: TableInfoManager,
    view_info_manager: ViewInfoManager,
    datanode_table_manager: DatanodeTableManager,
    catalog_manager: CatalogManager,
    schema_manager: SchemaManager,
    table_route_manager: TableRouteManager,
    tombstone_manager: TombstoneManager,
    kv_backend: KvBackendRef,
}

Fields

table_name_manager: TableNameManager

table_info_manager: TableInfoManager

view_info_manager: ViewInfoManager

datanode_table_manager: DatanodeTableManager

catalog_manager: CatalogManager

schema_manager: SchemaManager

table_route_manager: TableRouteManager

tombstone_manager: TombstoneManager

kv_backend: KvBackendRef

Implementations

impl TableMetadataManager

pub fn new(kv_backend: KvBackendRef) -> Self

pub async fn init(&self) -> Result<()>

pub fn table_name_manager(&self) -> &TableNameManager

pub fn table_info_manager(&self) -> &TableInfoManager

pub fn view_info_manager(&self) -> &ViewInfoManager

pub fn datanode_table_manager(&self) -> &DatanodeTableManager

pub fn catalog_manager(&self) -> &CatalogManager

pub fn schema_manager(&self) -> &SchemaManager

pub fn table_route_manager(&self) -> &TableRouteManager

pub fn kv_backend(&self) -> &KvBackendRef

pub async fn get_full_table_info( &self, table_id: TableId, ) -> Result<(Option<DeserializedValueWithBytes<TableInfoValue>>, Option<DeserializedValueWithBytes<TableRouteValue>>)>

pub async fn create_view_metadata( &self, view_info: RawTableInfo, raw_logical_plan: Vec<u8>, table_names: HashSet<TableName>, columns: Vec<String>, plan_columns: Vec<String>, definition: String, ) -> Result<()>

Creates metadata for view and returns an error if different metadata exists. The caller MUST ensure it has the exclusive access to TableNameKey. Parameters include:

• view_info: the encoded logical plan
• table_names: the resolved fully table names in logical plan
• columns: the view columns
• plan_columns: the original plan columns
• definition: The SQL to create the view

pub async fn create_table_metadata( &self, table_info: RawTableInfo, table_route_value: TableRouteValue, region_wal_options: HashMap<RegionNumber, String>, ) -> Result<()>

Creates metadata for table and returns an error if different metadata exists. The caller MUST ensure it has the exclusive access to TableNameKey.

pub fn create_logical_tables_metadata_chunk_size(&self) -> usize

pub async fn create_logical_tables_metadata( &self, tables_data: Vec<(RawTableInfo, TableRouteValue)>, ) -> Result<()>

Creates metadata for multiple logical tables and return an error if different metadata exists.

fn table_metadata_keys( &self, table_id: TableId, table_name: &TableName, table_route_value: &TableRouteValue, ) -> Result<Vec<Vec<u8>>>

pub async fn delete_table_metadata( &self, table_id: TableId, table_name: &TableName, table_route_value: &TableRouteValue, ) -> Result<()>

Deletes metadata for table logically. The caller MUST ensure it has the exclusive access to TableNameKey.

pub async fn delete_table_metadata_tombstone( &self, table_id: TableId, table_name: &TableName, table_route_value: &TableRouteValue, ) -> Result<()>

Deletes metadata tombstone for table permanently. The caller MUST ensure it has the exclusive access to TableNameKey.

pub async fn restore_table_metadata( &self, table_id: TableId, table_name: &TableName, table_route_value: &TableRouteValue, ) -> Result<()>

Restores metadata for table. The caller MUST ensure it has the exclusive access to TableNameKey.

pub async fn destroy_table_metadata( &self, table_id: TableId, table_name: &TableName, table_route_value: &TableRouteValue, ) -> Result<()>

Deletes metadata for table permanently. The caller MUST ensure it has the exclusive access to TableNameKey.

fn view_info_keys( &self, view_id: TableId, view_name: &TableName, ) -> Result<Vec<Vec<u8>>>

pub async fn destroy_view_info( &self, view_id: TableId, view_name: &TableName, ) -> Result<()>

Deletes metadata for view permanently. The caller MUST ensure it has the exclusive access to ViewNameKey.

pub async fn rename_table( &self, current_table_info_value: &DeserializedValueWithBytes<TableInfoValue>, new_table_name: String, ) -> Result<()>

Renames the table name and returns an error if different metadata exists. The caller MUST ensure it has the exclusive access to old and new TableNameKeys, and the new TableNameKey MUST be empty.

pub async fn update_table_info( &self, current_table_info_value: &DeserializedValueWithBytes<TableInfoValue>, region_distribution: Option<RegionDistribution>, new_table_info: RawTableInfo, ) -> Result<()>

Updates table info and returns an error if different metadata exists. And cascade-ly update all redundant table options for each region if region_distribution is present.

pub async fn update_view_info( &self, view_id: TableId, current_view_info_value: &DeserializedValueWithBytes<ViewInfoValue>, new_view_info: Vec<u8>, table_names: HashSet<TableName>, columns: Vec<String>, plan_columns: Vec<String>, definition: String, ) -> Result<()>

Updates view info and returns an error if different metadata exists. Parameters include:

• view_id: the view id
• current_view_info_value: the current view info for CAS checking
• new_view_info: the encoded logical plan
• table_names: the resolved fully table names in logical plan
• columns: the view columns
• plan_columns: the original plan columns
• definition: The SQL to create the view

pub fn batch_update_table_info_value_chunk_size(&self) -> usize

pub async fn batch_update_table_info_values( &self, table_info_value_pairs: Vec<(DeserializedValueWithBytes<TableInfoValue>, RawTableInfo)>, ) -> Result<()>

pub async fn update_table_route( &self, table_id: TableId, region_info: RegionInfo, current_table_route_value: &DeserializedValueWithBytes<TableRouteValue>, new_region_routes: Vec<RegionRoute>, new_region_options: &HashMap<String, String>, new_region_wal_options: &HashMap<RegionNumber, String>, ) -> Result<()>

pub async fn update_leader_region_status<F>( &self, table_id: TableId, current_table_route_value: &DeserializedValueWithBytes<TableRouteValue>, next_region_route_status: F, ) -> Result<()>

where F: Fn(&RegionRoute) -> Option<Option<LeaderState>>,

Updates the leader status of the RegionRoute.