Struct DdlManager 

pub struct DdlManager {
    ddl_context: DdlContext,
    procedure_manager: ProcedureManagerRef,
    repartition_procedure_factory: RepartitionProcedureFactoryRef,
}

The DdlManager provides the ability to execute Ddl.

Fields

ddl_context: DdlContext

procedure_manager: ProcedureManagerRef

repartition_procedure_factory: RepartitionProcedureFactoryRef

Implementations

impl DdlManager

pub fn try_new( ddl_context: DdlContext, procedure_manager: ProcedureManagerRef, repartition_procedure_factory: RepartitionProcedureFactoryRef, register_loaders: bool, ) -> Result<Self>

Returns a new DdlManager with all Ddl BoxedProcedureLoaders registered.

pub fn table_metadata_manager(&self) -> &TableMetadataManagerRef

Returns the TableMetadataManagerRef.

pub fn create_context(&self) -> DdlContext

Returns the DdlContext

pub fn register_loaders(&self) -> Result<()>

Registers all Ddl loaders.

async fn submit_repartition_task( &self, table_id: TableId, table_name: TableName, __arg3: Repartition, wait: bool, timeout: Duration, ) -> Result<(ProcedureId, Option<Output>)>

Submits a repartition procedure for the specified table.

This creates a repartition procedure using the provided table_id, table_name, and Repartition configuration, and then either executes it to completion or just submits it for asynchronous execution.

The Repartition argument contains the original (from_partition_exprs) and target (into_partition_exprs) partition expressions that define how the table should be repartitioned.

The wait flag controls whether this method waits for the repartition procedure to finish:

• If wait is true, the procedure is executed and this method awaits its completion, returning both the generated ProcedureId and the final Output of the procedure.
• If wait is false, the procedure is only submitted to the procedure manager for asynchronous execution, and this method returns the ProcedureId along with None as the output.

pub async fn submit_alter_table_task( &self, table_id: TableId, alter_table_task: AlterTableTask, ddl_options: DdlOptions, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes an alter table task.

pub async fn submit_create_table_task( &self, create_table_task: CreateTableTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a create table task.

pub async fn submit_create_view_task( &self, create_view_task: CreateViewTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a [CreateViewTask].

pub async fn submit_create_logical_table_tasks( &self, create_table_tasks: Vec<CreateTableTask>, physical_table_id: TableId, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a create multiple logical table tasks.

pub async fn submit_alter_logical_table_tasks( &self, alter_table_tasks: Vec<AlterTableTask>, physical_table_id: TableId, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes alter multiple table tasks.

pub async fn submit_drop_table_task( &self, drop_table_task: DropTableTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a drop table task.

pub async fn submit_create_database( &self, __arg1: CreateDatabaseTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a create database task.

pub async fn submit_drop_database( &self, __arg1: DropDatabaseTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a drop table task.

pub async fn submit_alter_database( &self, alter_database_task: AlterDatabaseTask, ) -> Result<(ProcedureId, Option<Output>)>

pub async fn submit_create_flow_task( &self, create_flow: CreateFlowTask, query_context: QueryContext, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a create flow task.

pub async fn submit_drop_flow_task( &self, drop_flow: DropFlowTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a drop flow task.

pub async fn submit_drop_view_task( &self, drop_view: DropViewTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a drop view task.

pub async fn submit_truncate_table_task( &self, truncate_table_task: TruncateTableTask, table_info_value: DeserializedValueWithBytes<TableInfoValue>, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a truncate table task.

pub async fn submit_comment_on_task( &self, comment_on_task: CommentOnTask, ) -> Result<(ProcedureId, Option<Output>)>

Submits and executes a comment on task.

async fn execute_procedure_and_wait( &self, procedure_with_id: ProcedureWithId, ) -> Result<(ProcedureId, Option<Output>)>

Executes a procedure and waits for the result.

async fn submit_procedure( &self, procedure_with_id: ProcedureWithId, ) -> Result<ProcedureId>

Submits a procedure and returns the procedure id.

pub async fn submit_ddl_task( &self, ctx: &ExecutorContext, request: SubmitDdlTaskRequest, ) -> Result<SubmitDdlTaskResponse>