Struct CreateLogicalTablesProcedure

pub struct CreateLogicalTablesProcedure {
    pub context: DdlContext,
    pub data: CreateTablesData,
}

Fields

context: DdlContext

data: CreateTablesData

Implementations

impl CreateLogicalTablesProcedure

pub(crate) fn check_input_tasks(&self) -> Result<()>

pub(crate) async fn check_tables_already_exist(&mut self) -> Result<()>

fn check_schema(&self) -> Result<()>

impl CreateLogicalTablesProcedure

pub(crate) async fn fill_physical_table_info(&mut self) -> Result<()>

pub(crate) async fn allocate_table_ids(&mut self) -> Result<()>

impl CreateLogicalTablesProcedure

pub(crate) fn make_request( &self, peer: &Peer, region_routes: &[RegionRoute], ) -> Result<RegionRequest>

fn create_region_request_builder( &self, task: &CreateTableTask, ) -> Result<CreateRequestBuilder>

impl CreateLogicalTablesProcedure

pub(crate) async fn update_physical_table_metadata(&mut self) -> Result<()>

pub(crate) async fn create_logical_tables_metadata( &mut self, ) -> Result<Vec<TableId>>

impl CreateLogicalTablesProcedure

pub const TYPE_NAME: &'static str = "metasrv-procedure::CreateLogicalTables"

pub fn new( cluster_id: ClusterId, tasks: Vec<CreateTableTask>, physical_table_id: TableId, context: DdlContext, ) -> Self

pub fn from_json(json: &str, context: DdlContext) -> ProcedureResult<Self>

pub(crate) async fn on_prepare(&mut self) -> Result<Status>

On the prepares step, it performs:

• Checks whether physical table exists.
• Checks whether logical tables exist.
• Allocates the table ids.
• Modify tasks to sort logical columns on their names.

Abort(non-retry):

• The physical table does not exist.
• Failed to check whether tables exist.
• One of logical tables has existing, and the table creation task without setting create_if_not_exists.

pub async fn on_datanode_create_regions(&mut self) -> Result<Status>

pub async fn on_create_metadata(&mut self) -> Result<Status>

Creates table metadata for logical tables and update corresponding physical table’s metadata.

Abort(not-retry):

• Failed to create table metadata.

async fn create_regions( &mut self, region_routes: &[RegionRoute], ) -> Result<Status>

Trait Implementations

impl Procedure for CreateLogicalTablesProcedure

fn type_name(&self) -> &str

Type name of the procedure.

fn execute<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 ProcedureContext, ) -> Pin<Box<dyn Future<Output = ProcedureResult<Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Execute the procedure.

fn dump(&self) -> ProcedureResult<String>

Dump the state of the procedure to a string.

fn lock_key(&self) -> LockKey

Returns the [LockKey] that this procedure needs to acquire.

fn rollback<'life0, 'life1, 'async_trait>( &'life0 mut self, _: &'life1 Context, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Rollback the failed procedure.

fn rollback_supported(&self) -> bool

Indicates whether it supports rolling back the procedure.

fn recover(&mut self) -> Result<(), Error>

The hook is called after the procedure recovery.