Rename UpdatableRALExecutor (#29769)

apache · Jan 18, 2024 · e6d4894 · e6d4894
1 parent 6b096d0
commit e6d4894
Show file tree

Hide file tree

Showing 38 changed files with 127 additions and 127 deletions.
diff --git a/...e/ral/update/DatabaseAwareRALUpdater.java → ...te/DatabaseAwareUpdatableRALExecutor.java b/...e/ral/update/DatabaseAwareRALUpdater.java → ...te/DatabaseAwareUpdatableRALExecutor.java
@@ -21,11 +21,11 @@
 import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
 
 /**
- * Database aware RAL updater.
+ * Database aware updatable RAL executor.
  * 
  * @param <T> type of SQL statement
  */
-public interface DatabaseAwareRALUpdater<T extends UpdatableRALStatement> extends RALUpdater<T> {
+public interface DatabaseAwareUpdatableRALExecutor<T extends UpdatableRALStatement> extends UpdatableRALExecutor<T> {
 
     /**
      * Set database.

diff --git a/...l/handler/type/ral/update/RALUpdater.java → ...type/ral/update/UpdatableRALExecutor.java b/...l/handler/type/ral/update/RALUpdater.java → ...type/ral/update/UpdatableRALExecutor.java
@@ -24,12 +24,12 @@
 import java.sql.SQLException;
 
 /**
- * RAL updater.
+ * Updatable RAL executor.
  * 
  * @param <T> type of updatable RAL statement
  */
 @SingletonSPI
-public interface RALUpdater<T extends UpdatableRALStatement> extends TypedSPI {
+public interface UpdatableRALExecutor<T extends UpdatableRALStatement> extends TypedSPI {
 
     /**
      * Execute update.

diff --git a/.../handler/update/DropStreamingUpdater.java → ...handler/update/DropStreamingExecutor.java b/.../handler/update/DropStreamingUpdater.java → ...handler/update/DropStreamingExecutor.java
@@ -20,15 +20,15 @@
 import org.apache.shardingsphere.data.pipeline.cdc.distsql.statement.DropStreamingStatement;
 import org.apache.shardingsphere.data.pipeline.cdc.api.CDCJobAPI;
 import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 
 import java.sql.SQLException;
 
 /**
- * Drop streaming updater.
+ * Drop streaming executor.
  */
-public final class DropStreamingUpdater implements RALUpdater<DropStreamingStatement> {
+public final class DropStreamingExecutor implements UpdatableRALExecutor<DropStreamingStatement> {
 
     private final CDCJobAPI jobAPI = (CDCJobAPI) TypedSPILoader.getService(TransmissionJobAPI.class, "STREAMING");
 

diff --git a/...dler/update/CheckMigrationJobUpdater.java → ...ler/update/CheckMigrationJobExecutor.java b/...dler/update/CheckMigrationJobUpdater.java → ...ler/update/CheckMigrationJobExecutor.java
@@ -27,7 +27,7 @@
 import org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.CreateConsistencyCheckJobParameter;
 import org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobType;
 import org.apache.shardingsphere.data.pipeline.scenario.migration.config.MigrationJobConfiguration;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.distsql.segment.AlgorithmSegment;
 import org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.CheckMigrationStatement;
@@ -36,9 +36,9 @@
 import java.util.Properties;
 
 /**
- * Check migration job updater.
+ * Check migration job executor.
  */
-public final class CheckMigrationJobUpdater implements RALUpdater<CheckMigrationStatement> {
+public final class CheckMigrationJobExecutor implements UpdatableRALExecutor<CheckMigrationStatement> {
 
     private final ConsistencyCheckJobAPI checkJobAPI = new ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
 

diff --git a/...andler/update/CommitMigrationUpdater.java → ...ndler/update/CommitMigrationExecutor.java b/...andler/update/CommitMigrationUpdater.java → ...ndler/update/CommitMigrationExecutor.java
@@ -18,16 +18,16 @@
 package org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update;
 
 import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.CommitMigrationStatement;
 
 import java.sql.SQLException;
 
 /**
- * Commit migration updater.
+ * Commit migration executor.
  */
-public final class CommitMigrationUpdater implements RALUpdater<CommitMigrationStatement> {
+public final class CommitMigrationExecutor implements UpdatableRALExecutor<CommitMigrationStatement> {
 
     @Override
     public void executeUpdate(final CommitMigrationStatement sqlStatement) throws SQLException {

diff --git a/...ler/update/DropMigrationCheckUpdater.java → ...er/update/DropMigrationCheckExecutor.java b/...ler/update/DropMigrationCheckUpdater.java → ...er/update/DropMigrationCheckExecutor.java
@@ -19,13 +19,13 @@
 
 import org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
 import org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.DropMigrationCheckStatement;
 
 /**
- * Drop migration check updater.
+ * Drop migration check executor.
  */
-public final class DropMigrationCheckUpdater implements RALUpdater<DropMigrationCheckStatement> {
+public final class DropMigrationCheckExecutor implements UpdatableRALExecutor<DropMigrationCheckStatement> {
 
     private final ConsistencyCheckJobAPI jobAPI = new ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
 

diff --git a/...l/handler/update/MigrateTableUpdater.java → .../handler/update/MigrateTableExecutor.java b/...l/handler/update/MigrateTableUpdater.java → .../handler/update/MigrateTableExecutor.java
@@ -23,17 +23,17 @@
 import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.MigrateTableStatement;
 import org.apache.shardingsphere.data.pipeline.scenario.migration.api.MigrationJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseAwareRALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseAwareUpdatableRALExecutor;
 import org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
 import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
 import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
 import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 
 /**
- * Migrate table updater.
+ * Migrate table executor.
  */
 @Setter
-public final class MigrateTableUpdater implements DatabaseAwareRALUpdater<MigrateTableStatement> {
+public final class MigrateTableExecutor implements DatabaseAwareUpdatableRALExecutor<MigrateTableStatement> {
 
     private ShardingSphereDatabase database;
 

diff --git a/...terMigrationSourceStorageUnitUpdater.java → ...erMigrationSourceStorageUnitExecutor.java b/...terMigrationSourceStorageUnitUpdater.java → ...erMigrationSourceStorageUnitExecutor.java
@@ -20,7 +20,7 @@
 import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
 import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
 import org.apache.shardingsphere.data.pipeline.scenario.migration.api.MigrationJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.distsql.handler.validate.DataSourcePoolPropertiesValidateHandler;
 import org.apache.shardingsphere.distsql.segment.DataSourceSegment;
 import org.apache.shardingsphere.distsql.segment.HostnameAndPortBasedDataSourceSegment;
@@ -40,9 +40,9 @@
 import java.util.Map;
 
 /**
- * Register migration source storage unit updater.
+ * Register migration source storage unit executor.
  */
-public final class RegisterMigrationSourceStorageUnitUpdater implements RALUpdater<RegisterMigrationSourceStorageUnitStatement> {
+public final class RegisterMigrationSourceStorageUnitExecutor implements UpdatableRALExecutor<RegisterMigrationSourceStorageUnitStatement> {
 
     private final MigrationJobAPI jobAPI = (MigrationJobAPI) TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION");
 

diff --git a/...dler/update/RollbackMigrationUpdater.java → ...ler/update/RollbackMigrationExecutor.java b/...dler/update/RollbackMigrationUpdater.java → ...ler/update/RollbackMigrationExecutor.java
@@ -18,16 +18,16 @@
 package org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update;
 
 import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.RollbackMigrationStatement;
 
 import java.sql.SQLException;
 
 /**
- * Rollback migration updater.
+ * Rollback migration executor.
  */
-public final class RollbackMigrationUpdater implements RALUpdater<RollbackMigrationStatement> {
+public final class RollbackMigrationExecutor implements UpdatableRALExecutor<RollbackMigrationStatement> {
 
     @Override
     public void executeUpdate(final RollbackMigrationStatement sqlStatement) throws SQLException {

diff --git a/...er/update/StartMigrationCheckUpdater.java → ...r/update/StartMigrationCheckExecutor.java b/...er/update/StartMigrationCheckUpdater.java → ...r/update/StartMigrationCheckExecutor.java
@@ -19,13 +19,13 @@
 
 import org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
 import org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StartMigrationCheckStatement;
 
 /**
- * Start migration check updater.
+ * Start migration check executor.
  */
-public final class StartMigrationCheckUpdater implements RALUpdater<StartMigrationCheckStatement> {
+public final class StartMigrationCheckExecutor implements UpdatableRALExecutor<StartMigrationCheckStatement> {
 
     private final ConsistencyCheckJobAPI jobAPI = new ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
 

diff --git a/...handler/update/StartMigrationUpdater.java → ...andler/update/StartMigrationExecutor.java b/...handler/update/StartMigrationUpdater.java → ...andler/update/StartMigrationExecutor.java
@@ -19,13 +19,13 @@
 
 import org.apache.shardingsphere.data.pipeline.core.job.service.PipelineJobManager;
 import org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobType;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StartMigrationStatement;
 
 /**
- * Start migration updater.
+ * Start migration executor.
  */
-public final class StartMigrationUpdater implements RALUpdater<StartMigrationStatement> {
+public final class StartMigrationExecutor implements UpdatableRALExecutor<StartMigrationStatement> {
 
     private final PipelineJobManager jobManager = new PipelineJobManager(new MigrationJobType());
 

diff --git a/...ler/update/StopMigrationCheckUpdater.java → ...er/update/StopMigrationCheckExecutor.java b/...ler/update/StopMigrationCheckUpdater.java → ...er/update/StopMigrationCheckExecutor.java
@@ -19,13 +19,13 @@
 
 import org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.ConsistencyCheckJobType;
 import org.apache.shardingsphere.data.pipeline.scenario.consistencycheck.api.ConsistencyCheckJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StopMigrationCheckStatement;
 
 /**
- * Stop migration check updater.
+ * Stop migration check executor.
  */
-public final class StopMigrationCheckUpdater implements RALUpdater<StopMigrationCheckStatement> {
+public final class StopMigrationCheckExecutor implements UpdatableRALExecutor<StopMigrationCheckStatement> {
 
     private final ConsistencyCheckJobAPI jobAPI = new ConsistencyCheckJobAPI(new ConsistencyCheckJobType());
 

diff --git a/.../handler/update/StopMigrationUpdater.java → ...handler/update/StopMigrationExecutor.java b/.../handler/update/StopMigrationUpdater.java → ...handler/update/StopMigrationExecutor.java
@@ -19,13 +19,13 @@
 
 import org.apache.shardingsphere.data.pipeline.core.job.service.PipelineJobManager;
 import org.apache.shardingsphere.data.pipeline.scenario.migration.MigrationJobType;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StopMigrationStatement;
 
 /**
- * Stop migration updater.
+ * Stop migration executor.
  */
-public final class StopMigrationUpdater implements RALUpdater<StopMigrationStatement> {
+public final class StopMigrationExecutor implements UpdatableRALExecutor<StopMigrationStatement> {
 
     private final PipelineJobManager jobManager = new PipelineJobManager(new MigrationJobType());
 

diff --git a/...terMigrationSourceStorageUnitUpdater.java → ...erMigrationSourceStorageUnitExecutor.java b/...terMigrationSourceStorageUnitUpdater.java → ...erMigrationSourceStorageUnitExecutor.java
@@ -20,15 +20,15 @@
 import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
 import org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI;
 import org.apache.shardingsphere.data.pipeline.scenario.migration.api.MigrationJobAPI;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
 import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 import org.apache.shardingsphere.data.pipeline.migration.distsql.statement.UnregisterMigrationSourceStorageUnitStatement;
 
 /**
- * Unregister migration source storage unit updater.
+ * Unregister migration source storage unit executor.
  */
-public final class UnregisterMigrationSourceStorageUnitUpdater implements RALUpdater<UnregisterMigrationSourceStorageUnitStatement> {
+public final class UnregisterMigrationSourceStorageUnitExecutor implements UpdatableRALExecutor<UnregisterMigrationSourceStorageUnitStatement> {
 
     private final MigrationJobAPI jobAPI = (MigrationJobAPI) TypedSPILoader.getService(TransmissionJobAPI.class, "MIGRATION");
 

diff --git a/...istsql.handler.type.ral.update.RALUpdater → ...dler.type.ral.update.UpdatableRALExecutor b/...istsql.handler.type.ral.update.RALUpdater → ...dler.type.ral.update.UpdatableRALExecutor
@@ -15,15 +15,15 @@
 # limitations under the License.
 #
 
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.MigrateTableUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StartMigrationUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StopMigrationUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.CommitMigrationUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.RollbackMigrationUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.RegisterMigrationSourceStorageUnitUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.UnregisterMigrationSourceStorageUnitUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.CheckMigrationJobUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StartMigrationCheckUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StopMigrationCheckUpdater
-org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.DropMigrationCheckUpdater
-org.apache.shardingsphere.data.pipeline.cdc.distsql.handler.update.DropStreamingUpdater
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.MigrateTableExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StartMigrationExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StopMigrationExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.CommitMigrationExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.RollbackMigrationExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.RegisterMigrationSourceStorageUnitExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.UnregisterMigrationSourceStorageUnitExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.CheckMigrationJobExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StartMigrationCheckExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.StopMigrationCheckExecutor
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.update.DropMigrationCheckExecutor
+org.apache.shardingsphere.data.pipeline.cdc.distsql.handler.update.DropStreamingExecutor
diff --git a/...g/apache/shardingsphere/proxy/backend/handler/distsql/ral/UpdatableRALBackendHandler.java b/...g/apache/shardingsphere/proxy/backend/handler/distsql/ral/UpdatableRALBackendHandler.java
@@ -18,8 +18,8 @@
 package org.apache.shardingsphere.proxy.backend.handler.distsql.ral;
 
 import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseAwareRALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseAwareUpdatableRALExecutor;
 import org.apache.shardingsphere.distsql.statement.ral.UpdatableRALStatement;
 import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 import org.apache.shardingsphere.proxy.backend.context.ProxyContext;
@@ -45,9 +45,9 @@ public final class UpdatableRALBackendHandler<T extends UpdatableRALStatement> i
     @SuppressWarnings("unchecked")
     @Override
     public ResponseHeader execute() throws SQLException {
-        RALUpdater<T> updater = TypedSPILoader.getService(RALUpdater.class, sqlStatement.getClass());
-        if (updater instanceof DatabaseAwareRALUpdater) {
-            ((DatabaseAwareRALUpdater<T>) updater).setDatabase(ProxyContext.getInstance().getDatabase(DatabaseNameUtils.getDatabaseName(sqlStatement, connectionSession)));
+        UpdatableRALExecutor<T> updater = TypedSPILoader.getService(UpdatableRALExecutor.class, sqlStatement.getClass());
+        if (updater instanceof DatabaseAwareUpdatableRALExecutor) {
+            ((DatabaseAwareUpdatableRALExecutor<T>) updater).setDatabase(ProxyContext.getInstance().getDatabase(DatabaseNameUtils.getDatabaseName(sqlStatement, connectionSession)));
         }
         updater.executeUpdate((T) sqlStatement);
         return new UpdateResponseHeader(sqlStatement);

diff --git a/...ingStorageUnitStatusStatementUpdater.java → ...ngStorageUnitStatusStatementExecutor.java b/...ingStorageUnitStatusStatementUpdater.java → ...ngStorageUnitStatusStatementExecutor.java
@@ -21,7 +21,7 @@
 import com.google.common.base.Strings;
 import lombok.Setter;
 import org.apache.shardingsphere.distsql.handler.exception.storageunit.MissingRequiredStorageUnitsException;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseAwareRALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.DatabaseAwareUpdatableRALExecutor;
 import org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
 import org.apache.shardingsphere.infra.exception.core.external.sql.type.generic.UnsupportedSQLOperationException;
 import org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
@@ -51,10 +51,10 @@
 import java.util.stream.Collectors;
 
 /**
- * Set readwrite-splitting storage unit status updater.
+ * Set readwrite-splitting storage unit status executor.
  */
 @Setter
-public final class AlterReadwriteSplittingStorageUnitStatusStatementUpdater implements DatabaseAwareRALUpdater<AlterReadwriteSplittingStorageUnitStatusStatement> {
+public final class AlterReadwriteSplittingStorageUnitStatusStatementExecutor implements DatabaseAwareUpdatableRALExecutor<AlterReadwriteSplittingStorageUnitStatusStatement> {
 
     private static final String DISABLE = "DISABLE";
 

diff --git a/...datable/AlterTransmissionRuleUpdater.java → ...atable/AlterTransmissionRuleExecutor.java b/...datable/AlterTransmissionRuleUpdater.java → ...atable/AlterTransmissionRuleExecutor.java
@@ -21,16 +21,16 @@
 import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
 import org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType;
 import org.apache.shardingsphere.data.pipeline.core.metadata.PipelineProcessConfigurationPersistService;
-import org.apache.shardingsphere.distsql.handler.type.ral.update.RALUpdater;
+import org.apache.shardingsphere.distsql.handler.type.ral.update.UpdatableRALExecutor;
 import org.apache.shardingsphere.distsql.statement.ral.updatable.AlterTransmissionRuleStatement;
 import org.apache.shardingsphere.infra.instance.metadata.InstanceType;
 import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
 import org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.converter.TransmissionProcessConfigurationSegmentConverter;
 
 /**
- * Alter transmission rule updater.
+ * Alter transmission rule executor.
  */
-public final class AlterTransmissionRuleUpdater implements RALUpdater<AlterTransmissionRuleStatement> {
+public final class AlterTransmissionRuleExecutor implements UpdatableRALExecutor<AlterTransmissionRuleStatement> {
 
     private final PipelineProcessConfigurationPersistService processConfigPersistService = new PipelineProcessConfigurationPersistService();