Struct DropTableExecutor

pub struct DropTableExecutor {
    table: TableName,
    table_id: TableId,
    drop_if_exists: bool,
}

DropTableExecutor performs:

• Drops the metadata of the table.
• Invalidates the cache on the Frontend nodes.
• Drops the regions on the Datanode nodes.

Fields

table: TableName

table_id: TableId

drop_if_exists: bool

Implementations

impl DropTableExecutor

pub fn new(table: TableName, table_id: TableId, drop_if_exists: bool) -> Self

Returns the DropTableExecutor.

impl DropTableExecutor

pub async fn on_prepare(&self, ctx: &DdlContext) -> Result<Control<()>>

Checks whether table exists.

• Early returns if table not exists and drop_if_exists is true.
• Throws an error if table not exists and drop_if_exists is false.

pub async fn on_delete_metadata( &self, ctx: &DdlContext, table_route_value: &TableRouteValue, region_wal_options: &HashMap<RegionNumber, WalOptions>, ) -> Result<()>

Deletes the table metadata logically.

pub async fn on_delete_metadata_tombstone( &self, ctx: &DdlContext, table_route_value: &TableRouteValue, region_wal_options: &HashMap<u32, WalOptions>, ) -> Result<()>

Deletes the table metadata tombstone permanently.

pub async fn on_destroy_metadata( &self, ctx: &DdlContext, table_route_value: &TableRouteValue, region_wal_options: &HashMap<u32, WalOptions>, ) -> Result<()>

Deletes metadata for table permanently.

pub async fn on_restore_metadata( &self, ctx: &DdlContext, table_route_value: &TableRouteValue, region_wal_options: &HashMap<u32, WalOptions>, ) -> Result<()>

Restores the table metadata.

pub async fn invalidate_table_cache(&self, ctx: &DdlContext) -> Result<()>

Invalidates frontend caches

pub async fn on_drop_regions( &self, ctx: &DdlContext, region_routes: &[RegionRoute], fast_path: bool, ) -> Result<()>

Drops region on datanode.