This is an automated email from the ASF dual-hosted git repository.
zhaojinchao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 770eb7737a7 Move migration statements to pipeline module (#30200)
770eb7737a7 is described below
commit 770eb7737a733e866a5159f4ff31acc9a21f58e5
Author: Raigor <[email protected]>
AuthorDate: Mon Feb 19 21:54:08 2024 +0800
Move migration statements to pipeline module (#30200)
---
.../handler/query/ShowStreamingRuleExecutor.java | 2 +-
.../query}/ShowTransmissionRuleQueryResult.java | 2 +-
.../update}/AlterTransmissionRuleExecutor.java | 5 +-
...issionProcessConfigurationSegmentConverter.java | 2 +-
.../handler/query}/ShowMigrationRuleExecutor.java | 6 +-
...stsql.handler.engine.query.DistSQLQueryExecutor | 1 +
...sql.handler.engine.update.DistSQLUpdateExecutor | 1 +
.../src/main/antlr4/imports/migration/Keyword.g4 | 16 +++++
.../main/antlr4/imports/migration/RALStatement.g4 | 44 +++++++++++++
.../parser/autogen/MigrationDistSQLStatement.g4 | 4 +-
.../parser/core/CDCDistSQLStatementVisitor.java | 2 +-
.../core/MigrationDistSQLStatementVisitor.java | 77 ++++++++++++++++++++++
.../statement}/AlterTransmissionRuleStatement.java | 2 +-
.../statement}/ShowMigrationRuleStatement.java | 2 +-
.../engine/src/main/antlr4/imports/Keyword.g4 | 36 ----------
.../engine/src/main/antlr4/imports/RALStatement.g4 | 44 -------------
.../parser/autogen/KernelDistSQLStatement.g4 | 2 -
.../core/kernel/KernelDistSQLStatementVisitor.java | 77 ----------------------
...stsql.handler.engine.query.DistSQLQueryExecutor | 1 -
...sql.handler.engine.update.DistSQLUpdateExecutor | 1 -
.../AlterTransmissionRuleStatementAssert.java | 2 +-
.../UpdatablePipelineRALStatementAssert.java | 2 +-
22 files changed, 155 insertions(+), 176 deletions(-)
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/query/ShowStreamingRuleExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/query/ShowStreamingRuleExecutor.java
index d17fe3f510a..fa453915fa0 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/query/ShowStreamingRuleExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/handler/query/ShowStreamingRuleExecutor.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.data.pipeline.cdc.distsql.handler.query;
import
org.apache.shardingsphere.data.pipeline.cdc.distsql.statement.ShowStreamingRuleStatement;
-import
org.apache.shardingsphere.data.pipeline.distsql.ShowTransmissionRuleQueryResult;
+import
org.apache.shardingsphere.data.pipeline.distsql.handler.query.ShowTransmissionRuleQueryResult;
import
org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor;
import
org.apache.shardingsphere.infra.merge.result.impl.local.LocalDataQueryResultRow;
import org.apache.shardingsphere.mode.manager.ContextManager;
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/ShowTransmissionRuleQueryResult.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/query/ShowTransmissionRuleQueryResult.java
similarity index 97%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/ShowTransmissionRuleQueryResult.java
rename to
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/query/ShowTransmissionRuleQueryResult.java
index ad10d8cfa57..436c280d815 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/ShowTransmissionRuleQueryResult.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/query/ShowTransmissionRuleQueryResult.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.data.pipeline.distsql;
+package org.apache.shardingsphere.data.pipeline.distsql.handler.query;
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.data.pipeline.core.job.progress.config.PipelineProcessConfiguration;
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterTransmissionRuleExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/update/AlterTransmissionRuleExecutor.java
similarity index 89%
rename from
proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterTransmissionRuleExecutor.java
rename to
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/update/AlterTransmissionRuleExecutor.java
index 78b9fd18848..cdcbdeaf5d6 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/AlterTransmissionRuleExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/update/AlterTransmissionRuleExecutor.java
@@ -15,18 +15,17 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable;
+package org.apache.shardingsphere.data.pipeline.distsql.handler.update;
import org.apache.shardingsphere.data.pipeline.core.context.PipelineContextKey;
import
org.apache.shardingsphere.data.pipeline.core.job.progress.config.PipelineProcessConfiguration;
import org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType;
import
org.apache.shardingsphere.data.pipeline.core.metadata.PipelineProcessConfigurationPersistService;
+import
org.apache.shardingsphere.data.pipeline.distsql.statement.AlterTransmissionRuleStatement;
import
org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor;
-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.mode.manager.ContextManager;
-import
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.converter.TransmissionProcessConfigurationSegmentConverter;
/**
* Alter transmission rule executor.
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/converter/TransmissionProcessConfigurationSegmentConverter.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/update/TransmissionProcessConfigurationSegmentConverter.java
similarity index 97%
rename from
proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/converter/TransmissionProcessConfigurationSegmentConverter.java
rename to
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/update/TransmissionProcessConfigurationSegmentConverter.java
index a46cbeef1df..a64716cb31f 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/updatable/converter/TransmissionProcessConfigurationSegmentConverter.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/update/TransmissionProcessConfigurationSegmentConverter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.converter;
+package org.apache.shardingsphere.data.pipeline.distsql.handler.update;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/query/ShowMigrationRuleExecutor.java
similarity index 86%
rename from
proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java
rename to
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/query/ShowMigrationRuleExecutor.java
index 39504cb4e9f..ea3c78e547a 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/ral/queryable/ShowMigrationRuleExecutor.java
+++
b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/handler/query/ShowMigrationRuleExecutor.java
@@ -15,11 +15,11 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable;
+package
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.query;
-import
org.apache.shardingsphere.data.pipeline.distsql.ShowTransmissionRuleQueryResult;
+import
org.apache.shardingsphere.data.pipeline.distsql.handler.query.ShowTransmissionRuleQueryResult;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.ShowMigrationRuleStatement;
import
org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor;
-import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowMigrationRuleStatement;
import
org.apache.shardingsphere.infra.merge.result.impl.local.LocalDataQueryResultRow;
import org.apache.shardingsphere.mode.manager.ContextManager;
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
index a9920b3bf35..dde0f2ca463 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
+++
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
@@ -15,6 +15,7 @@
# limitations under the License.
#
+org.apache.shardingsphere.data.pipeline.migration.distsql.handler.query.ShowMigrationRuleExecutor
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.query.ShowMigrationListExecutor
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.query.ShowMigrationJobStatusExecutor
org.apache.shardingsphere.data.pipeline.migration.distsql.handler.query.ShowMigrationCheckStatusExecutor
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
index ac63ca73456..0a598ba06bd 100644
---
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
+++
b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
@@ -15,6 +15,7 @@
# limitations under the License.
#
+org.apache.shardingsphere.data.pipeline.distsql.handler.update.AlterTransmissionRuleExecutor
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
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
index ad501f9cabe..2c78122441a 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
+++
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
@@ -194,3 +194,19 @@ UNIT
UNITS
: U N I T S
;
+
+ALTER
+ : A L T E R
+ ;
+
+RULE
+ : R U L E
+ ;
+
+READ
+ : R E A D
+ ;
+
+WRITE
+ : W R I T E
+ ;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
index 721f0271388..4330340b7f8 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
+++
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
@@ -19,6 +19,46 @@ grammar RALStatement;
import BaseRule;
+showMigrationRule
+ : SHOW MIGRATION RULE
+ ;
+
+alterMigrationRule
+ : ALTER MIGRATION RULE transmissionRule?
+ ;
+
+transmissionRule
+ : LP_ readDefinition? (COMMA_? writeDefinition)? (COMMA_? streamChannel)?
RP_
+ ;
+
+readDefinition
+ : READ LP_ workerThread? (COMMA_? batchSize)? (COMMA_? shardingSize)?
(COMMA_? rateLimiter)? RP_
+ ;
+
+writeDefinition
+ : WRITE LP_ workerThread? (COMMA_? batchSize)? (COMMA_? rateLimiter)? RP_
+ ;
+
+workerThread
+ : WORKER_THREAD EQ_ intValue
+ ;
+
+batchSize
+ : BATCH_SIZE EQ_ intValue
+ ;
+
+shardingSize
+ : SHARDING_SIZE EQ_ intValue
+ ;
+
+rateLimiter
+ : RATE_LIMITER LP_ algorithmDefinition RP_
+ ;
+
+streamChannel
+ : STREAM_CHANNEL LP_ algorithmDefinition RP_
+ ;
+
migrateTable
: MIGRATE TABLE sourceTableName INTO targetTableName
;
@@ -146,3 +186,7 @@ registerMigrationSourceStorageUnit
unregisterMigrationSourceStorageUnit
: UNREGISTER MIGRATION SOURCE STORAGE UNIT storageUnitName (COMMA_
storageUnitName)*
;
+
+intValue
+ : INT_
+ ;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
index 5590ee03965..32776c0ae3f 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
+++
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
@@ -20,7 +20,9 @@ grammar MigrationDistSQLStatement;
import Symbol, RALStatement, RQLStatement;
execute
- : (showMigrationList
+ : (showMigrationRule
+ | alterMigrationRule
+ | showMigrationList
| showMigrationStatus
| migrateTable
| startMigration
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
index 1f1dc54c1d1..b5be97becc9 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
+++
b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/distsql/parser/core/CDCDistSQLStatementVisitor.java
@@ -42,7 +42,7 @@ import
org.apache.shardingsphere.distsql.parser.autogen.CDCDistSQLStatementParse
import org.apache.shardingsphere.distsql.segment.AlgorithmSegment;
import org.apache.shardingsphere.distsql.segment.ReadOrWriteSegment;
import org.apache.shardingsphere.distsql.segment.TransmissionRuleSegment;
-import
org.apache.shardingsphere.distsql.statement.ral.updatable.AlterTransmissionRuleStatement;
+import
org.apache.shardingsphere.data.pipeline.distsql.statement.AlterTransmissionRuleStatement;
import org.apache.shardingsphere.sql.parser.api.ASTNode;
import org.apache.shardingsphere.sql.parser.api.visitor.SQLVisitor;
import
org.apache.shardingsphere.sql.parser.sql.common.value.identifier.IdentifierValue;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
index 754b6cd4d90..f3678ddec99 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
+++
b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
@@ -27,6 +27,7 @@ import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.Regis
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.RollbackMigrationStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.ShowMigrationCheckStatusStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.ShowMigrationListStatement;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.ShowMigrationRuleStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.ShowMigrationSourceStorageUnitsStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.ShowMigrationStatusStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.StartMigrationCheckStatement;
@@ -38,6 +39,8 @@ import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.pojo.
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementBaseVisitor;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.AlgorithmDefinitionContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.AlterMigrationRuleContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.BatchSizeContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.CheckMigrationContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.CommitMigrationContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.DropMigrationCheckContext;
@@ -45,11 +48,15 @@ import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatemen
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.PasswordContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.PropertiesDefinitionContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.PropertyContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.RateLimiterContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ReadDefinitionContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.RegisterMigrationSourceStorageUnitContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.RollbackMigrationContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ShardingSizeContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ShowMigrationCheckAlgorithmsContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ShowMigrationCheckStatusContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ShowMigrationListContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ShowMigrationRuleContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ShowMigrationSourceStorageUnitsContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.ShowMigrationStatusContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.SourceTableNameContext;
@@ -58,13 +65,20 @@ import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatemen
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.StopMigrationCheckContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.StopMigrationContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.StorageUnitDefinitionContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.StreamChannelContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.TargetTableNameContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.TransmissionRuleContext;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.UnregisterMigrationSourceStorageUnitContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.WorkerThreadContext;
+import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser.WriteDefinitionContext;
import org.apache.shardingsphere.distsql.segment.AlgorithmSegment;
import org.apache.shardingsphere.distsql.segment.DataSourceSegment;
import
org.apache.shardingsphere.distsql.segment.HostnameAndPortBasedDataSourceSegment;
+import org.apache.shardingsphere.distsql.segment.ReadOrWriteSegment;
+import org.apache.shardingsphere.distsql.segment.TransmissionRuleSegment;
import org.apache.shardingsphere.distsql.segment.URLBasedDataSourceSegment;
import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowPluginsStatement;
+import
org.apache.shardingsphere.data.pipeline.distsql.statement.AlterTransmissionRuleStatement;
import org.apache.shardingsphere.infra.datanode.DataNode;
import org.apache.shardingsphere.sql.parser.api.ASTNode;
import org.apache.shardingsphere.sql.parser.api.visitor.SQLVisitor;
@@ -82,6 +96,69 @@ import java.util.stream.Collectors;
*/
public final class MigrationDistSQLStatementVisitor extends
MigrationDistSQLStatementBaseVisitor<ASTNode> implements SQLVisitor<ASTNode> {
+ @Override
+ public ASTNode visitShowMigrationRule(final ShowMigrationRuleContext ctx) {
+ return new ShowMigrationRuleStatement();
+ }
+
+ @Override
+ public ASTNode visitAlterMigrationRule(final AlterMigrationRuleContext
ctx) {
+ TransmissionRuleSegment segment = null == ctx.transmissionRule() ? null
+ : (TransmissionRuleSegment) visit(ctx.transmissionRule());
+ return new AlterTransmissionRuleStatement("MIGRATION", segment);
+ }
+
+ @Override
+ public ASTNode visitTransmissionRule(final TransmissionRuleContext ctx) {
+ TransmissionRuleSegment result = new TransmissionRuleSegment();
+ if (null != ctx.readDefinition()) {
+ result.setReadSegment((ReadOrWriteSegment)
visit(ctx.readDefinition()));
+ }
+ if (null != ctx.writeDefinition()) {
+ result.setWriteSegment((ReadOrWriteSegment)
visit(ctx.writeDefinition()));
+ }
+ if (null != ctx.streamChannel()) {
+ result.setStreamChannel((AlgorithmSegment)
visit(ctx.streamChannel()));
+ }
+ return result;
+ }
+
+ @Override
+ public ASTNode visitReadDefinition(final ReadDefinitionContext ctx) {
+ return new ReadOrWriteSegment(getWorkerThread(ctx.workerThread()),
getBatchSize(ctx.batchSize()), getShardingSize(ctx.shardingSize()),
getAlgorithmSegment(ctx.rateLimiter()));
+ }
+
+ @Override
+ public ASTNode visitWriteDefinition(final WriteDefinitionContext ctx) {
+ return new ReadOrWriteSegment(getWorkerThread(ctx.workerThread()),
getBatchSize(ctx.batchSize()), getAlgorithmSegment(ctx.rateLimiter()));
+ }
+
+ private AlgorithmSegment getAlgorithmSegment(final RateLimiterContext ctx)
{
+ return null == ctx ? null : (AlgorithmSegment) visit(ctx);
+ }
+
+ @Override
+ public ASTNode visitRateLimiter(final RateLimiterContext ctx) {
+ return visit(ctx.algorithmDefinition());
+ }
+
+ @Override
+ public ASTNode visitStreamChannel(final StreamChannelContext ctx) {
+ return visit(ctx.algorithmDefinition());
+ }
+
+ private Integer getWorkerThread(final WorkerThreadContext ctx) {
+ return null == ctx ? null : Integer.parseInt(ctx.intValue().getText());
+ }
+
+ private Integer getBatchSize(final BatchSizeContext ctx) {
+ return null == ctx ? null : Integer.parseInt(ctx.intValue().getText());
+ }
+
+ private Integer getShardingSize(final ShardingSizeContext ctx) {
+ return null == ctx ? null : Integer.parseInt(ctx.intValue().getText());
+ }
+
@Override
public ASTNode visitMigrateTable(final MigrateTableContext ctx) {
SourceTargetEntry sourceTargetEntry =
buildSourceTargetEntry(ctx.sourceTableName(), ctx.targetTableName());
diff --git
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/statement/ral/updatable/AlterTransmissionRuleStatement.java
b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/statement/AlterTransmissionRuleStatement.java
similarity index 95%
rename from
parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/statement/ral/updatable/AlterTransmissionRuleStatement.java
rename to
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/statement/AlterTransmissionRuleStatement.java
index 3a6a7fcf1b8..d031b258b0b 100644
---
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/statement/ral/updatable/AlterTransmissionRuleStatement.java
+++
b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/statement/AlterTransmissionRuleStatement.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.statement.ral.updatable;
+package org.apache.shardingsphere.data.pipeline.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/statement/ral/queryable/show/ShowMigrationRuleStatement.java
b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/ShowMigrationRuleStatement.java
similarity index 93%
rename from
parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/statement/ral/queryable/show/ShowMigrationRuleStatement.java
rename to
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/ShowMigrationRuleStatement.java
index 9c36705c088..b28821327d2 100644
---
a/parser/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/statement/ral/queryable/show/ShowMigrationRuleStatement.java
+++
b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/ShowMigrationRuleStatement.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.statement.ral.queryable.show;
+package org.apache.shardingsphere.data.pipeline.migration.distsql.statement;
import
org.apache.shardingsphere.distsql.statement.ral.pipeline.migration.QueryableMigrationRALStatement;
diff --git a/parser/distsql/engine/src/main/antlr4/imports/Keyword.g4
b/parser/distsql/engine/src/main/antlr4/imports/Keyword.g4
index 8809526da79..f520facabf9 100644
--- a/parser/distsql/engine/src/main/antlr4/imports/Keyword.g4
+++ b/parser/distsql/engine/src/main/antlr4/imports/Keyword.g4
@@ -151,10 +151,6 @@ RULES
: R U L E S
;
-RULE
- : R U L E
- ;
-
REFRESH
: R E F R E S H
;
@@ -239,38 +235,6 @@ INFO
: I N F O
;
-MIGRATION
- : M I G R A T I O N
- ;
-
-READ
- : R E A D
- ;
-
-WRITE
- : W R I T E
- ;
-
-WORKER_THREAD
- : W O R K E R UL_ T H R E A D
- ;
-
-BATCH_SIZE
- : B A T C H UL_ S I Z E
- ;
-
-SHARDING_SIZE
- : S H A R D I N G UL_ S I Z E
- ;
-
-RATE_LIMITER
- : R A T E UL_ L I M I T E R
- ;
-
-STREAM_CHANNEL
- : S T R E A M UL_ C H A N N E L
- ;
-
STORAGE
: S T O R A G E
;
diff --git a/parser/distsql/engine/src/main/antlr4/imports/RALStatement.g4
b/parser/distsql/engine/src/main/antlr4/imports/RALStatement.g4
index 6e20ae6b3fb..a9dae402431 100644
--- a/parser/distsql/engine/src/main/antlr4/imports/RALStatement.g4
+++ b/parser/distsql/engine/src/main/antlr4/imports/RALStatement.g4
@@ -99,14 +99,6 @@ convertYamlConfiguration
: CONVERT YAML CONFIGURATION FROM FILE filePath
;
-showMigrationRule
- : SHOW MIGRATION RULE
- ;
-
-alterMigrationRule
- : ALTER MIGRATION RULE transmissionRule?
- ;
-
lockCluster
: LOCK CLUSTER WITH lockStrategy
;
@@ -123,38 +115,6 @@ showKeyGenerateAlgorithmPlugins
: SHOW KEY GENERATE ALGORITHM PLUGINS
;
-transmissionRule
- : LP_ readDefinition? (COMMA_? writeDefinition)? (COMMA_? streamChannel)?
RP_
- ;
-
-readDefinition
- : READ LP_ workerThread? (COMMA_? batchSize)? (COMMA_? shardingSize)?
(COMMA_? rateLimiter)? RP_
- ;
-
-writeDefinition
- : WRITE LP_ workerThread? (COMMA_? batchSize)? (COMMA_? rateLimiter)? RP_
- ;
-
-workerThread
- : WORKER_THREAD EQ_ intValue
- ;
-
-batchSize
- : BATCH_SIZE EQ_ intValue
- ;
-
-shardingSize
- : SHARDING_SIZE EQ_ intValue
- ;
-
-rateLimiter
- : RATE_LIMITER LP_ algorithmDefinition RP_
- ;
-
-streamChannel
- : STREAM_CHANNEL LP_ algorithmDefinition RP_
- ;
-
confPath
: STRING_
;
@@ -199,10 +159,6 @@ label
: IDENTIFIER_
;
-intValue
- : INT_
- ;
-
showLike
: LIKE likePattern
;
diff --git
a/parser/distsql/engine/src/main/antlr4/org/apache/shardingsphere/distsql/parser/autogen/KernelDistSQLStatement.g4
b/parser/distsql/engine/src/main/antlr4/org/apache/shardingsphere/distsql/parser/autogen/KernelDistSQLStatement.g4
index 79f3e142795..ef2d33f8589 100644
---
a/parser/distsql/engine/src/main/antlr4/org/apache/shardingsphere/distsql/parser/autogen/KernelDistSQLStatement.g4
+++
b/parser/distsql/engine/src/main/antlr4/org/apache/shardingsphere/distsql/parser/autogen/KernelDistSQLStatement.g4
@@ -46,8 +46,6 @@ execute
| importMetaData
| exportStorageNodes
| convertYamlConfiguration
- | showMigrationRule
- | alterMigrationRule
| lockCluster
| unlockCluster
| showPluginImplementations
diff --git
a/parser/distsql/engine/src/main/java/org/apache/shardingsphere/distsql/parser/core/kernel/KernelDistSQLStatementVisitor.java
b/parser/distsql/engine/src/main/java/org/apache/shardingsphere/distsql/parser/core/kernel/KernelDistSQLStatementVisitor.java
index 20972fedeaf..9b1a930bb98 100644
---
a/parser/distsql/engine/src/main/java/org/apache/shardingsphere/distsql/parser/core/kernel/KernelDistSQLStatementVisitor.java
+++
b/parser/distsql/engine/src/main/java/org/apache/shardingsphere/distsql/parser/core/kernel/KernelDistSQLStatementVisitor.java
@@ -21,9 +21,7 @@ import org.antlr.v4.runtime.tree.ParseTree;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementBaseVisitor;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.AlgorithmDefinitionContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.AlterComputeNodeContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.AlterMigrationRuleContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.AlterStorageUnitContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.BatchSizeContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ConvertYamlConfigurationContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.DatabaseNameContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.DisableComputeNodeContext;
@@ -43,13 +41,10 @@ import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementPa
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.PasswordContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.PropertiesDefinitionContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.PropertyContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.RateLimiterContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ReadDefinitionContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.RefreshDatabaseMetadataContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.RefreshTableMetadataContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.RegisterStorageUnitContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.SetDistVariableContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShardingSizeContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowComputeNodeInfoContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowComputeNodeModeContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowComputeNodesContext;
@@ -57,24 +52,17 @@ import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementPa
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowDistVariablesContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowKeyGenerateAlgorithmPluginsContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowLogicalTablesContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowMigrationRuleContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowPluginImplementationsContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowRulesUsedStorageUnitContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowStorageUnitsContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.ShowTableMetadataContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.StorageUnitDefinitionContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.StreamChannelContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.TransmissionRuleContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.UnlabelComputeNodeContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.UnlockClusterContext;
import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.UnregisterStorageUnitContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.WorkerThreadContext;
-import
org.apache.shardingsphere.distsql.parser.autogen.KernelDistSQLStatementParser.WriteDefinitionContext;
import org.apache.shardingsphere.distsql.segment.AlgorithmSegment;
import org.apache.shardingsphere.distsql.segment.DataSourceSegment;
import
org.apache.shardingsphere.distsql.segment.HostnameAndPortBasedDataSourceSegment;
-import org.apache.shardingsphere.distsql.segment.ReadOrWriteSegment;
-import org.apache.shardingsphere.distsql.segment.TransmissionRuleSegment;
import org.apache.shardingsphere.distsql.segment.URLBasedDataSourceSegment;
import
org.apache.shardingsphere.distsql.statement.ral.queryable.convert.ConvertYamlConfigurationStatement;
import
org.apache.shardingsphere.distsql.statement.ral.queryable.export.ExportDatabaseConfigurationStatement;
@@ -85,11 +73,9 @@ import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowComput
import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowComputeNodesStatement;
import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowDistVariableStatement;
import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowDistVariablesStatement;
-import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowMigrationRuleStatement;
import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowPluginsStatement;
import
org.apache.shardingsphere.distsql.statement.ral.queryable.show.ShowTableMetaDataStatement;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.AlterComputeNodeStatement;
-import
org.apache.shardingsphere.distsql.statement.ral.updatable.AlterTransmissionRuleStatement;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.ImportDatabaseConfigurationStatement;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.ImportMetaDataStatement;
import
org.apache.shardingsphere.distsql.statement.ral.updatable.LabelComputeNodeStatement;
@@ -308,47 +294,6 @@ public final class KernelDistSQLStatementVisitor extends
KernelDistSQLStatementB
return new ImportMetaDataStatement(null == ctx.metaDataValue() ? null
: getQuotedContent(ctx.metaDataValue()), getIdentifierValue(ctx.filePath()));
}
- @Override
- public ASTNode visitShowMigrationRule(final ShowMigrationRuleContext ctx) {
- return new ShowMigrationRuleStatement();
- }
-
- @Override
- public ASTNode visitAlterMigrationRule(final AlterMigrationRuleContext
ctx) {
- TransmissionRuleSegment segment = null == ctx.transmissionRule() ? null
- : (TransmissionRuleSegment) visit(ctx.transmissionRule());
- return new AlterTransmissionRuleStatement("MIGRATION", segment);
- }
-
- @Override
- public ASTNode visitTransmissionRule(final TransmissionRuleContext ctx) {
- TransmissionRuleSegment result = new TransmissionRuleSegment();
- if (null != ctx.readDefinition()) {
- result.setReadSegment((ReadOrWriteSegment)
visit(ctx.readDefinition()));
- }
- if (null != ctx.writeDefinition()) {
- result.setWriteSegment((ReadOrWriteSegment)
visit(ctx.writeDefinition()));
- }
- if (null != ctx.streamChannel()) {
- result.setStreamChannel((AlgorithmSegment)
visit(ctx.streamChannel()));
- }
- return result;
- }
-
- @Override
- public ASTNode visitReadDefinition(final ReadDefinitionContext ctx) {
- return new ReadOrWriteSegment(getWorkerThread(ctx.workerThread()),
getBatchSize(ctx.batchSize()), getShardingSize(ctx.shardingSize()),
getAlgorithmSegment(ctx.rateLimiter()));
- }
-
- @Override
- public ASTNode visitWriteDefinition(final WriteDefinitionContext ctx) {
- return new ReadOrWriteSegment(getWorkerThread(ctx.workerThread()),
getBatchSize(ctx.batchSize()), getAlgorithmSegment(ctx.rateLimiter()));
- }
-
- private AlgorithmSegment getAlgorithmSegment(final RateLimiterContext ctx)
{
- return null == ctx ? null : (AlgorithmSegment) visit(ctx);
- }
-
@Override
public ASTNode visitAlgorithmDefinition(final AlgorithmDefinitionContext
ctx) {
return new
AlgorithmSegment(getIdentifierValue(ctx.algorithmTypeName()),
buildProperties(ctx.propertiesDefinition()));
@@ -365,18 +310,6 @@ public final class KernelDistSQLStatementVisitor extends
KernelDistSQLStatementB
return result;
}
- private Integer getWorkerThread(final WorkerThreadContext ctx) {
- return null == ctx ? null : Integer.parseInt(ctx.intValue().getText());
- }
-
- private Integer getBatchSize(final BatchSizeContext ctx) {
- return null == ctx ? null : Integer.parseInt(ctx.intValue().getText());
- }
-
- private Integer getShardingSize(final ShardingSizeContext ctx) {
- return null == ctx ? null : Integer.parseInt(ctx.intValue().getText());
- }
-
@Override
public ASTNode visitLockCluster(final LockClusterContext ctx) {
return new LockClusterStatement((AlgorithmSegment)
visitAlgorithmDefinition(ctx.lockStrategy().algorithmDefinition()));
@@ -387,16 +320,6 @@ public final class KernelDistSQLStatementVisitor extends
KernelDistSQLStatementB
return new UnlockClusterStatement();
}
- @Override
- public ASTNode visitRateLimiter(final RateLimiterContext ctx) {
- return visit(ctx.algorithmDefinition());
- }
-
- @Override
- public ASTNode visitStreamChannel(final StreamChannelContext ctx) {
- return visit(ctx.algorithmDefinition());
- }
-
private String getIdentifierValue(final ParseTree context) {
return null == context ? null : new
IdentifierValue(context.getText()).getValue();
}
diff --git
a/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
b/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
index 951c8248f9e..0fd9be4cca3 100644
---
a/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
+++
b/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
@@ -25,7 +25,6 @@
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ConvertYam
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowDistVariableExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowDistVariablesExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowTableMetaDataExecutor
-org.apache.shardingsphere.proxy.backend.handler.distsql.ral.queryable.ShowMigrationRuleExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.rul.FormatSQLExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.rul.ParseDistSQLExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.rul.PreviewExecutor
diff --git
a/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
b/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
index eb0b26ad4a5..f857f96d25c 100644
---
a/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
+++
b/proxy/backend/core/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
@@ -15,7 +15,6 @@
# limitations under the License.
#
-org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.AlterTransmissionRuleExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.LabelComputeNodeExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.UnlabelComputeNodeExecutor
org.apache.shardingsphere.proxy.backend.handler.distsql.ral.updatable.SetInstanceStatusExecutor
diff --git
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/AlterTransmissionRuleStatementAssert.java
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/AlterTransmissionRuleStatementAssert.java
index ea137249f57..ba0c1e33e22 100644
---
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/AlterTransmissionRuleStatementAssert.java
+++
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/AlterTransmissionRuleStatementAssert.java
@@ -21,7 +21,7 @@ import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.apache.shardingsphere.distsql.segment.AlgorithmSegment;
import org.apache.shardingsphere.distsql.segment.ReadOrWriteSegment;
-import
org.apache.shardingsphere.distsql.statement.ral.updatable.AlterTransmissionRuleStatement;
+import
org.apache.shardingsphere.data.pipeline.distsql.statement.AlterTransmissionRuleStatement;
import
org.apache.shardingsphere.test.it.sql.parser.internal.asserts.SQLCaseAssertContext;
import
org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.domain.statement.ral.AlterTransmissionRuleStatementTestCase;
import
org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.segment.impl.distsql.ExpectedAlgorithm;
diff --git
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/UpdatablePipelineRALStatementAssert.java
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/UpdatablePipelineRALStatementAssert.java
index 148c0809d0b..47763368623 100644
---
a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/UpdatablePipelineRALStatementAssert.java
+++
b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/pipeline/UpdatablePipelineRALStatementAssert.java
@@ -21,7 +21,7 @@ import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.data.pipeline.cdc.distsql.statement.DropStreamingStatement;
import
org.apache.shardingsphere.distsql.statement.ral.pipeline.UpdatablePipelineRALStatement;
-import
org.apache.shardingsphere.distsql.statement.ral.updatable.AlterTransmissionRuleStatement;
+import
org.apache.shardingsphere.data.pipeline.distsql.statement.AlterTransmissionRuleStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.CheckMigrationStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.CommitMigrationStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.MigrateTableStatement;
