RepartitionProcedureFactory

Trait RepartitionProcedureFactory 

Source
pub trait RepartitionProcedureFactory: Send + Sync {
    // Required methods
    fn create(
        &self,
        ddl_ctx: &DdlContext,
        table_name: TableName,
        table_id: TableId,
        from_exprs: Vec<String>,
        to_exprs: Vec<String>,
    ) -> Result<BoxedProcedure, BoxedError>;
    fn register_loaders(
        &self,
        ddl_ctx: &DdlContext,
        procedure_manager: &ProcedureManagerRef,
    ) -> Result<(), BoxedError>;
}

Required Methods§

Source

fn create( &self, ddl_ctx: &DdlContext, table_name: TableName, table_id: TableId, from_exprs: Vec<String>, to_exprs: Vec<String>, ) -> Result<BoxedProcedure, BoxedError>

Source

fn register_loaders( &self, ddl_ctx: &DdlContext, procedure_manager: &ProcedureManagerRef, ) -> Result<(), BoxedError>

Implementors§