Struct AlterTableExecutor

pub struct AlterTableExecutor {
    table: TableName,
    table_id: TableId,
    new_table_name: Option<String>,
}

AlterTableExecutor performs:

• Alters the metadata of the table.
• Alters regions on the datanode nodes.

Fields

table: TableName

table_id: TableId

new_table_name: Option<String>

The new table name if the alter kind is rename table.

Implementations

impl AlterTableExecutor

pub fn new( table: TableName, table_id: TableId, new_table_name: Option<String>, ) -> Self

Creates a new AlterTableExecutor.

pub(crate) async fn on_prepare( &self, table_metadata_manager: &TableMetadataManagerRef, ) -> Result<()>

Prepares to alter the table.

Checks:

• The new table name doesn’t exist (rename).
• Table exists.

pub(crate) fn validate_alter_table_expr( table_info: &RawTableInfo, alter_table_expr: AlterTableExpr, ) -> Result<TableInfo>

Validates the alter table expression and builds the new table info.

This validation is performed early to ensure the alteration is valid before proceeding to the on_alter_metadata state, where regions have already been altered. Building the new table info here allows us to catch any issues with the alteration before committing metadata changes.

pub(crate) async fn on_alter_metadata( &self, table_metadata_manager: &TableMetadataManagerRef, current_table_info_value: &DeserializedValueWithBytes<TableInfoValue>, region_distribution: Option<&RegionDistribution>, raw_table_info: RawTableInfo, column_metadatas: &[ColumnMetadata], ) -> Result<()>

Updates table metadata for alter table operation.

pub(crate) async fn on_alter_regions( &self, node_manager: &NodeManagerRef, region_routes: &[RegionRoute], kind: Option<Kind>, ) -> Vec<Result<RegionResponse>>

Alters regions on the datanode nodes.

pub(crate) async fn invalidate_table_cache( &self, cache_invalidator: &CacheInvalidatorRef, ) -> Result<()>

Invalidates cache for the table.