This is an automated email from the ASF dual-hosted git repository.
zhangliang 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 1ade6078e83 Add data-pipeline-scenario-migration-core and
data-pipeline-scenario-migration-distsql modules (#36054)
1ade6078e83 is described below
commit 1ade6078e836d50d85b0be71a6ab2e8f0683e7ac
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Jul 22 19:42:58 2025 +0800
Add data-pipeline-scenario-migration-core and
data-pipeline-scenario-migration-distsql modules (#36054)
* Add shardingsphere-data-pipeline-scenario-migration-core module
* Add shardingsphere-data-pipeline-scenario-migration-distsql module
* Add shardingsphere-data-pipeline-scenario-migration-distsql module
* Add shardingsphere-data-pipeline-scenario-migration-distsql module
* Add shardingsphere-data-pipeline-scenario-migration-distsql module
* Add shardingsphere-data-pipeline-scenario-migration-distsql module
* Add shardingsphere-data-pipeline-scenario-migration-distsql module
* Add shardingsphere-data-pipeline-scenario-migration-distsql module
---
kernel/data-pipeline/distsql/handler/pom.xml | 21 +----
...sql.handler.engine.update.DistSQLUpdateExecutor | 11 ---
.../parser/src/main/antlr4/imports/cdc/BaseRule.g4 | 56 -------------
.../parser/src/main/antlr4/imports/cdc/Keyword.g4 | 92 ----------------------
.../src/main/antlr4/imports/cdc/RALStatement.g4 | 76 ------------------
.../parser/src/main/antlr4/imports/cdc/Symbol.g4 | 62 ---------------
.../src/main/antlr4/imports/migration/Alphabet.g4 | 48 -----------
.../src/main/antlr4/imports/migration/Literals.g4 | 34 --------
kernel/data-pipeline/distsql/pom.xml | 1 -
.../updatable/AlterTransmissionRuleStatement.java | 3 +-
.../scenario/migration/{ => core}/pom.xml | 6 +-
.../pipeline/scenario/migration/MigrationJob.java | 0
.../migration/MigrationJobExecutorCallback.java | 0
.../scenario/migration/MigrationJobId.java | 0
.../scenario/migration/MigrationJobType.java | 0
.../scenario/migration/api/MigrationJobAPI.java | 0
.../MigrationDataConsistencyChecker.java | 0
.../config/MigrationJobConfiguration.java | 0
.../config/MigrationTaskConfiguration.java | 4 +-
.../yaml/config/YamlMigrationJobConfiguration.java | 0
.../YamlMigrationJobConfigurationSwapper.java | 0
.../migration/context/MigrationJobItemContext.java | 8 +-
.../MigrationIncrementalDumperContextCreator.java | 0
.../MigrationJobConfigurationChangedProcessor.java | 0
.../migration/preparer/MigrationJobPreparer.java | 6 +-
.../migration/preparer/MigrationPrepareLock.java | 0
...e.data.pipeline.core.job.api.TransmissionJobAPI | 0
...ere.data.pipeline.core.job.type.PipelineJobType | 0
...nfig.processor.JobConfigurationChangedProcessor | 0
.../core/job/id/PipelineJobIdUtilsTest.java | 0
.../migration}/distsql/handler/pom.xml | 17 ++--
.../MigrationCheckAlgorithmTypeAndClassMapper.java | 0
.../query/ShowMigrationCheckStatusExecutor.java | 0
.../query/ShowMigrationJobStatusExecutor.java | 0
.../migration/query/ShowMigrationListExecutor.java | 0
.../migration/query/ShowMigrationRuleExecutor.java | 0
.../ShowMigrationSourceStorageUnitsExecutor.java | 0
.../update/CheckMigrationJobExecutor.java | 0
.../migration/update/CommitMigrationExecutor.java | 0
.../update/DropMigrationCheckExecutor.java | 0
.../migration/update/MigrateTableExecutor.java | 0
...RegisterMigrationSourceStorageUnitExecutor.java | 0
.../update/RollbackMigrationExecutor.java | 0
.../update/StartMigrationCheckExecutor.java | 0
.../migration/update/StartMigrationExecutor.java | 0
.../update/StopMigrationCheckExecutor.java | 0
.../migration/update/StopMigrationExecutor.java | 0
...registerMigrationSourceStorageUnitExecutor.java | 0
...stsql.handler.engine.query.DistSQLQueryExecutor | 0
...sql.handler.engine.update.DistSQLUpdateExecutor | 1 -
...er.executor.ral.plugin.PluginTypeAndClassMapper | 0
...rationCheckAlgorithmTypeAndClassMapperTest.java | 0
.../migration}/distsql/parser/pom.xml | 18 +----
.../src/main/antlr4/imports/migration}/Alphabet.g4 | 0
.../src/main/antlr4/imports/migration/BaseRule.g4 | 0
.../src/main/antlr4/imports/migration/Keyword.g4 | 0
.../src/main/antlr4/imports/migration}/Literals.g4 | 0
.../main/antlr4/imports/migration/RALStatement.g4 | 0
.../main/antlr4/imports/migration/RQLStatement.g4 | 0
.../src/main/antlr4/imports/migration/Symbol.g4 | 0
.../parser/autogen/MigrationDistSQLStatement.g4 | 0
.../distsql/parser/core/MigrationDistSQLLexer.java | 0
.../parser/core/MigrationDistSQLParser.java | 2 +-
.../core/MigrationDistSQLStatementVisitor.java | 14 ++--
.../facade/MigrationDistSQLParserFacade.java | 2 +-
...e.distsql.parser.engine.spi.DistSQLParserFacade | 0
.../{ => scenario/migration}/distsql/pom.xml | 4 +-
.../migration/{ => distsql/statement}/pom.xml | 9 +--
.../distsql/statement/MigrationRALStatement.java | 0
.../distsql/statement/pojo/SourceTargetEntry.java | 0
.../queryable/QueryableMigrationRALStatement.java | 0
.../ShowMigrationCheckStatusStatement.java | 0
.../queryable/ShowMigrationListStatement.java | 0
.../queryable/ShowMigrationRuleStatement.java | 0
.../ShowMigrationSourceStorageUnitsStatement.java | 0
.../queryable/ShowMigrationStatusStatement.java | 0
.../updatable/CheckMigrationStatement.java | 0
.../updatable/CommitMigrationStatement.java | 0
.../updatable/DropMigrationCheckStatement.java | 0
.../statement/updatable/MigrateTableStatement.java | 0
...egisterMigrationSourceStorageUnitStatement.java | 0
.../updatable/RollbackMigrationStatement.java | 0
.../updatable/StartMigrationCheckStatement.java | 0
.../updatable/StartMigrationStatement.java | 0
.../updatable/StopMigrationCheckStatement.java | 0
.../updatable/StopMigrationStatement.java | 0
...egisterMigrationSourceStorageUnitStatement.java | 0
.../updatable/UpdatableMigrationRALStatement.java | 0
kernel/data-pipeline/scenario/migration/pom.xml | 17 ++--
proxy/backend/core/pom.xml | 11 +--
test/it/parser/pom.xml | 4 +-
test/it/pipeline/pom.xml | 2 +-
92 files changed, 48 insertions(+), 481 deletions(-)
diff --git a/kernel/data-pipeline/distsql/handler/pom.xml
b/kernel/data-pipeline/distsql/handler/pom.xml
index 6c845a777b8..eb77a2d5e03 100644
--- a/kernel/data-pipeline/distsql/handler/pom.xml
+++ b/kernel/data-pipeline/distsql/handler/pom.xml
@@ -34,30 +34,13 @@
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-scenario-consistency-check</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-cdc-core</artifactId>
+
<artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-parser</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-test-fixture-database</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-consistency-check</artifactId>
<version>${project.version}</version>
- <scope>test</scope>
</dependency>
</dependencies>
</project>
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 3ccd33ff3f8..1aab22fdef5 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
@@ -16,14 +16,3 @@
#
org.apache.shardingsphere.data.pipeline.distsql.handler.transmission.update.AlterTransmissionRuleExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.MigrateTableExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StartMigrationExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StopMigrationExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.CommitMigrationExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.RollbackMigrationExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.RegisterMigrationSourceStorageUnitExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.UnregisterMigrationSourceStorageUnitExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.CheckMigrationJobExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StartMigrationCheckExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StopMigrationCheckExecutor
-org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.DropMigrationCheckExecutor
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/BaseRule.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/BaseRule.g4
deleted file mode 100644
index b7285f768da..00000000000
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/BaseRule.g4
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-grammar BaseRule;
-
-import Symbol, Keyword, Literals;
-
-algorithmDefinition
- : TYPE LP_ NAME EQ_ algorithmTypeName (COMMA_ propertiesDefinition)? RP_
- ;
-
-algorithmTypeName
- : STRING_
- ;
-
-propertiesDefinition
- : PROPERTIES LP_ properties? RP_
- ;
-
-properties
- : property (COMMA_ property)*
- ;
-
-property
- : key=STRING_ EQ_ value=literal
- ;
-
-literal
- : STRING_ | (MINUS_)? INT_ | TRUE | FALSE
- ;
-
-TRUE
- : T R U E
- ;
-
-FALSE
- : F A L S E
- ;
-
-intValue
- : INT_
- ;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Keyword.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Keyword.g4
deleted file mode 100644
index 68bd46e9b4a..00000000000
--- a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Keyword.g4
+++ /dev/null
@@ -1,92 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-lexer grammar Keyword;
-
-import Alphabet;
-
-WS
- : [ \t\r\n] + ->skip
- ;
-
-SHOW
- : S H O W
- ;
-
-STREAMING
- : S T R E A M I N G
- ;
-
-LIST
- : L I S T
- ;
-
-STATUS
- : S T A T U S
- ;
-
-DROP
- : D R O P
- ;
-
-TYPE
- : T Y P E
- ;
-
-NAME
- : N A M E
- ;
-
-PROPERTIES
- : P R O P E R T I E S
- ;
-
-ALTER
- : A L T E R
- ;
-
-RULE
- : R U L E
- ;
-
-READ
- : R E A D
- ;
-
-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
- ;
-
-WRITE
- : W R I T E
- ;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/RALStatement.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/RALStatement.g4
deleted file mode 100644
index 213747d09d7..00000000000
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/RALStatement.g4
+++ /dev/null
@@ -1,76 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-grammar RALStatement;
-
-import BaseRule;
-
-showStreamingRule
- : SHOW STREAMING RULE
- ;
-
-alterStreamingRule
- : ALTER STREAMING 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_
- ;
-
-showStreamingList
- : SHOW STREAMING LIST
- ;
-
-showStreamingStatus
- : SHOW STREAMING STATUS jobId
- ;
-
-dropStreaming
- : DROP STREAMING jobId
- ;
-
-jobId
- : INT_ | IDENTIFIER_ | STRING_
- ;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Symbol.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Symbol.g4
deleted file mode 100644
index 1da7901ec98..00000000000
--- a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Symbol.g4
+++ /dev/null
@@ -1,62 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-lexer grammar Symbol;
-
-AND_: '&&';
-OR_: '||';
-NOT_: '!';
-TILDE_: '~';
-VERTICALBAR_: '|';
-AMPERSAND_: '&';
-SIGNEDLEFTSHIFT_: '<<';
-SIGNEDRIGHTSHIFT_: '>>';
-CARET_: '^';
-MOD_: '%';
-COLON_: ':';
-PLUS_: '+';
-MINUS_: '-';
-ASTERISK_: '*';
-SLASH_: '/';
-BACKSLASH_: '\\';
-DOT_: '.';
-DOTASTERISK_: '.*';
-SAFEEQ_: '<=>';
-DEQ_: '==';
-EQ_: '=';
-NEQ_: '<>' | '!=';
-GT_: '>';
-GTE_: '>=';
-LT_: '<';
-LTE_: '<=';
-POUND_: '#';
-LP_: '(';
-RP_: ')';
-LBE_: '{';
-RBE_: '}';
-LBT_: '[';
-RBT_: ']';
-COMMA_: ',';
-DQ_: '"';
-SQ_: '\'';
-BQ_: '`';
-QUESTION_: '?';
-AT_: '@';
-SEMI_: ';';
-JSONSEPARATOR_: '->>';
-UL_: '_';
-DL_: '$';
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
deleted file mode 100644
index f7603cc7e63..00000000000
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-lexer grammar Alphabet;
-
-FOR_GENERATOR: 'DO NOT MATCH ANY THING, JUST FOR GENERATOR';
-
-fragment A: [Aa];
-fragment B: [Bb];
-fragment C: [Cc];
-fragment D: [Dd];
-fragment E: [Ee];
-fragment F: [Ff];
-fragment G: [Gg];
-fragment H: [Hh];
-fragment I: [Ii];
-fragment J: [Jj];
-fragment K: [Kk];
-fragment L: [Ll];
-fragment M: [Mm];
-fragment N: [Nn];
-fragment O: [Oo];
-fragment P: [Pp];
-fragment Q: [Qq];
-fragment R: [Rr];
-fragment S: [Ss];
-fragment T: [Tt];
-fragment U: [Uu];
-fragment V: [Vv];
-fragment W: [Ww];
-fragment X: [Xx];
-fragment Y: [Yy];
-fragment Z: [Zz];
-fragment UL_: '_';
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
deleted file mode 100644
index 68f6a1b07ed..00000000000
---
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-lexer grammar Literals;
-
-import Alphabet, Symbol;
-
-IDENTIFIER_
- : [A-Za-z_$0-9]*?[A-Za-z_$]+?[A-Za-z_$0-9]*
- | BQ_ ~'`'+ BQ_
- ;
-
-STRING_
- : (DQ_ ('\\'. | '""' | ~('"' | '\\'))* DQ_)
- | (SQ_ ('\\'. | '\'\'' | ~('\'' | '\\'))* SQ_)
- ;
-
-INT_
- : [0-9]+
- ;
diff --git a/kernel/data-pipeline/distsql/pom.xml
b/kernel/data-pipeline/distsql/pom.xml
index 99da2439a70..d3f05410d3a 100644
--- a/kernel/data-pipeline/distsql/pom.xml
+++ b/kernel/data-pipeline/distsql/pom.xml
@@ -29,7 +29,6 @@
<modules>
<module>statement</module>
- <module>parser</module>
<module>handler</module>
</modules>
</project>
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/statement/updatable/AlterTransmissionRuleStatement.java
b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/statement/updatable/AlterTransmissionRuleStatement.java
index 6ea1c209f45..fe9df57435a 100644
---
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/statement/updatable/AlterTransmissionRuleStatement.java
+++
b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/statement/updatable/AlterTransmissionRuleStatement.java
@@ -20,14 +20,13 @@ package
org.apache.shardingsphere.data.pipeline.distsql.statement.updatable;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.distsql.segment.TransmissionRuleSegment;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.UpdatableMigrationRALStatement;
/**
* Alter transmission rule statement.
*/
@RequiredArgsConstructor
@Getter
-public final class AlterTransmissionRuleStatement extends
UpdatableMigrationRALStatement {
+public final class AlterTransmissionRuleStatement extends
UpdatablePipelineRALStatement {
private final String jobTypeName;
diff --git a/kernel/data-pipeline/scenario/migration/pom.xml
b/kernel/data-pipeline/scenario/migration/core/pom.xml
similarity index 86%
copy from kernel/data-pipeline/scenario/migration/pom.xml
copy to kernel/data-pipeline/scenario/migration/core/pom.xml
index 2b8a819baec..8e952d6b58c 100644
--- a/kernel/data-pipeline/scenario/migration/pom.xml
+++ b/kernel/data-pipeline/scenario/migration/core/pom.xml
@@ -20,16 +20,16 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-scenario</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-core</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-statement</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJob.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJob.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJob.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJob.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobExecutorCallback.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobExecutorCallback.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobExecutorCallback.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobExecutorCallback.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobId.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobId.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobId.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobId.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationJobType.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/api/MigrationJobAPI.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/check/consistency/MigrationDataConsistencyChecker.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/check/consistency/MigrationDataConsistencyChecker.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/check/consistency/MigrationDataConsistencyChecker.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/check/consistency/MigrationDataConsistencyChecker.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationJobConfiguration.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationJobConfiguration.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationJobConfiguration.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationJobConfiguration.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationTaskConfiguration.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationTaskConfiguration.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationTaskConfiguration.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationTaskConfiguration.java
index d2f146083ae..d59f039d37c 100644
---
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationTaskConfiguration.java
+++
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationTaskConfiguration.java
@@ -20,10 +20,10 @@ package
org.apache.shardingsphere.data.pipeline.scenario.migration.config;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.ToString;
-import
org.apache.shardingsphere.data.pipeline.core.preparer.datasource.param.CreateTableConfiguration;
import
org.apache.shardingsphere.data.pipeline.core.importer.ImporterConfiguration;
-import
org.apache.shardingsphere.data.pipeline.core.task.config.PipelineTaskConfiguration;
import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.incremental.IncrementalDumperContext;
+import
org.apache.shardingsphere.data.pipeline.core.preparer.datasource.param.CreateTableConfiguration;
+import
org.apache.shardingsphere.data.pipeline.core.task.config.PipelineTaskConfiguration;
import java.util.Collection;
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/config/YamlMigrationJobConfiguration.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/config/YamlMigrationJobConfiguration.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/config/YamlMigrationJobConfiguration.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/config/YamlMigrationJobConfiguration.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/swapper/YamlMigrationJobConfigurationSwapper.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/swapper/YamlMigrationJobConfigurationSwapper.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/swapper/YamlMigrationJobConfigurationSwapper.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/yaml/swapper/YamlMigrationJobConfigurationSwapper.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationJobItemContext.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationJobItemContext.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationJobItemContext.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationJobItemContext.java
index 5cfbc0193eb..f4fe1f1598b 100644
---
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationJobItemContext.java
+++
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationJobItemContext.java
@@ -24,16 +24,16 @@ import
org.apache.commons.lang3.concurrent.ConcurrentException;
import org.apache.commons.lang3.concurrent.LazyInitializer;
import
org.apache.shardingsphere.data.pipeline.core.context.TransmissionJobItemContext;
import
org.apache.shardingsphere.data.pipeline.core.context.TransmissionProcessContext;
-import
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager;
import
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSource;
+import
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSourceManager;
+import org.apache.shardingsphere.data.pipeline.core.importer.sink.PipelineSink;
+import
org.apache.shardingsphere.data.pipeline.core.importer.sink.type.PipelineDataSourceSink;
import org.apache.shardingsphere.data.pipeline.core.job.JobStatus;
import
org.apache.shardingsphere.data.pipeline.core.job.progress.TransmissionJobItemProgress;
import
org.apache.shardingsphere.data.pipeline.core.job.progress.listener.PipelineJobUpdateProgress;
+import
org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService;
import
org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader;
import
org.apache.shardingsphere.data.pipeline.core.metadata.loader.StandardPipelineTableMetaDataLoader;
-import
org.apache.shardingsphere.data.pipeline.core.importer.sink.type.PipelineDataSourceSink;
-import org.apache.shardingsphere.data.pipeline.core.importer.sink.PipelineSink;
-import
org.apache.shardingsphere.data.pipeline.core.job.progress.persist.PipelineJobProgressPersistService;
import org.apache.shardingsphere.data.pipeline.core.task.PipelineTask;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.config.MigrationJobConfiguration;
import
org.apache.shardingsphere.data.pipeline.scenario.migration.config.MigrationTaskConfiguration;
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/ingest/dumper/MigrationIncrementalDumperContextCreator.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/ingest/dumper/MigrationIncrementalDumperContextCreator.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/ingest/dumper/MigrationIncrementalDumperContextCreator.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/ingest/dumper/MigrationIncrementalDumperContextCreator.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/MigrationJobConfigurationChangedProcessor.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/MigrationJobConfigurationChangedProcessor.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/MigrationJobConfigurationChangedProcessor.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/metadata/processor/MigrationJobConfigurationChangedProcessor.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationJobPreparer.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationJobPreparer.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationJobPreparer.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationJobPreparer.java
index 9c91e6c00ae..48a50a6e72a 100644
---
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationJobPreparer.java
+++
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationJobPreparer.java
@@ -65,12 +65,12 @@ import
org.apache.shardingsphere.infra.database.core.spi.DatabaseTypedSPILoader;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.exception.core.ShardingSpherePreconditions;
import
org.apache.shardingsphere.infra.exception.generic.UnsupportedSQLOperationException;
-import org.apache.shardingsphere.mode.lock.LockContext;
-import org.apache.shardingsphere.mode.lock.LockDefinition;
import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import org.apache.shardingsphere.infra.parser.SQLParserEngine;
-import
org.apache.shardingsphere.mode.manager.cluster.lock.global.GlobalLockDefinition;
+import org.apache.shardingsphere.mode.lock.LockContext;
+import org.apache.shardingsphere.mode.lock.LockDefinition;
import org.apache.shardingsphere.mode.manager.ContextManager;
+import
org.apache.shardingsphere.mode.manager.cluster.lock.global.GlobalLockDefinition;
import org.apache.shardingsphere.parser.rule.SQLParserRule;
import java.sql.SQLException;
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationPrepareLock.java
b/kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationPrepareLock.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationPrepareLock.java
rename to
kernel/data-pipeline/scenario/migration/core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/preparer/MigrationPrepareLock.java
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI
b/kernel/data-pipeline/scenario/migration/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI
rename to
kernel/data-pipeline/scenario/migration/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.api.TransmissionJobAPI
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType
b/kernel/data-pipeline/scenario/migration/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType
rename to
kernel/data-pipeline/scenario/migration/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.job.type.PipelineJobType
diff --git
a/kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.metadata.node.config.processor.JobConfigurationChangedProcessor
b/kernel/data-pipeline/scenario/migration/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.metadata.node.config.processor.JobConfigurationChangedProcessor
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.metadata.node.config.processor.JobConfigurationChangedProcessor
rename to
kernel/data-pipeline/scenario/migration/core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.metadata.node.config.processor.JobConfigurationChangedProcessor
diff --git
a/kernel/data-pipeline/scenario/migration/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/id/PipelineJobIdUtilsTest.java
b/kernel/data-pipeline/scenario/migration/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/id/PipelineJobIdUtilsTest.java
similarity index 100%
rename from
kernel/data-pipeline/scenario/migration/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/id/PipelineJobIdUtilsTest.java
rename to
kernel/data-pipeline/scenario/migration/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/job/id/PipelineJobIdUtilsTest.java
diff --git a/kernel/data-pipeline/distsql/handler/pom.xml
b/kernel/data-pipeline/scenario/migration/distsql/handler/pom.xml
similarity index 81%
copy from kernel/data-pipeline/distsql/handler/pom.xml
copy to kernel/data-pipeline/scenario/migration/distsql/handler/pom.xml
index 6c845a777b8..a0ff94cca35 100644
--- a/kernel/data-pipeline/distsql/handler/pom.xml
+++ b/kernel/data-pipeline/scenario/migration/distsql/handler/pom.xml
@@ -20,36 +20,31 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-distsql</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-distsql-handler</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-handler</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-infra-distsql-handler</artifactId>
+
<artifactId>shardingsphere-data-pipeline-distsql-handler</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-scenario-consistency-check</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-parser</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-cdc-core</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-core</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-parser</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-consistency-check</artifactId>
<version>${project.version}</version>
</dependency>
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapper.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapper.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapper.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapper.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationCheckStatusExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationCheckStatusExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationCheckStatusExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationCheckStatusExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationJobStatusExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationJobStatusExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationJobStatusExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationJobStatusExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationListExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationRuleExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationRuleExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationRuleExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationRuleExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationSourceStorageUnitsExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationSourceStorageUnitsExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationSourceStorageUnitsExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/ShowMigrationSourceStorageUnitsExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CheckMigrationJobExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CheckMigrationJobExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CheckMigrationJobExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CheckMigrationJobExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CommitMigrationExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CommitMigrationExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CommitMigrationExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/CommitMigrationExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/DropMigrationCheckExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/DropMigrationCheckExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/DropMigrationCheckExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/DropMigrationCheckExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/MigrateTableExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/MigrateTableExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/MigrateTableExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/MigrateTableExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RegisterMigrationSourceStorageUnitExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RegisterMigrationSourceStorageUnitExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RegisterMigrationSourceStorageUnitExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RegisterMigrationSourceStorageUnitExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RollbackMigrationExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RollbackMigrationExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RollbackMigrationExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/RollbackMigrationExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationCheckExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationCheckExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationCheckExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationCheckExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StartMigrationExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationCheckExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationCheckExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationCheckExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationCheckExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/StopMigrationExecutor.java
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/UnregisterMigrationSourceStorageUnitExecutor.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/UnregisterMigrationSourceStorageUnitExecutor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/UnregisterMigrationSourceStorageUnitExecutor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/update/UnregisterMigrationSourceStorageUnitExecutor.java
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/scenario/migration/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.query.DistSQLQueryExecutor
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/scenario/migration/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
similarity index 94%
copy from
kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
copy to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.engine.update.DistSQLUpdateExecutor
index 3ccd33ff3f8..d053d5b685c 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/scenario/migration/distsql/handler/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.data.pipeline.distsql.handler.transmission.update.AlterTransmissionRuleExecutor
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.MigrateTableExecutor
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StartMigrationExecutor
org.apache.shardingsphere.data.pipeline.distsql.handler.migration.update.StopMigrationExecutor
diff --git
a/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.executor.ral.plugin.PluginTypeAndClassMapper
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.executor.ral.plugin.PluginTypeAndClassMapper
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.executor.ral.plugin.PluginTypeAndClassMapper
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.handler.executor.ral.plugin.PluginTypeAndClassMapper
diff --git
a/kernel/data-pipeline/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapperTest.java
b/kernel/data-pipeline/scenario/migration/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapperTest.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapperTest.java
rename to
kernel/data-pipeline/scenario/migration/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/distsql/handler/migration/query/MigrationCheckAlgorithmTypeAndClassMapperTest.java
diff --git a/kernel/data-pipeline/distsql/parser/pom.xml
b/kernel/data-pipeline/scenario/migration/distsql/parser/pom.xml
similarity index 79%
rename from kernel/data-pipeline/distsql/parser/pom.xml
rename to kernel/data-pipeline/scenario/migration/distsql/parser/pom.xml
index 2ae43897510..d1e6b6c498c 100644
--- a/kernel/data-pipeline/distsql/parser/pom.xml
+++ b/kernel/data-pipeline/scenario/migration/distsql/parser/pom.xml
@@ -20,10 +20,10 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-distsql</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-distsql-parser</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-parser</artifactId>
<name>${project.artifactId}</name>
<dependencies>
@@ -39,7 +39,7 @@
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-statement</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
@@ -82,18 +82,6 @@
<visitor>true</visitor>
</configuration>
</execution>
- <execution>
- <id>antlr-cdc</id>
- <goals>
- <goal>antlr4</goal>
- </goals>
- <configuration>
-
<sourceDirectory>src/main/antlr4/cdc/</sourceDirectory>
-
<libDirectory>src/main/antlr4/imports/cdc/</libDirectory>
- <listener>false</listener>
- <visitor>true</visitor>
- </configuration>
- </execution>
</executions>
</plugin>
</plugins>
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Alphabet.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Alphabet.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Literals.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/cdc/Literals.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLLexer.java
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLLexer.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLLexer.java
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLLexer.java
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLParser.java
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLParser.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLParser.java
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLParser.java
index 4bf3773a21e..cd53ade5998 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLParser.java
+++
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLParser.java
@@ -20,8 +20,8 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.core;
import org.antlr.v4.runtime.CommonTokenStream;
import org.antlr.v4.runtime.TokenStream;
import
org.apache.shardingsphere.distsql.parser.autogen.MigrationDistSQLStatementParser;
-import org.apache.shardingsphere.sql.parser.api.parser.SQLParser;
import org.apache.shardingsphere.sql.parser.api.ASTNode;
+import org.apache.shardingsphere.sql.parser.api.parser.SQLParser;
import org.apache.shardingsphere.sql.parser.core.ParseASTNode;
/**
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/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
index 96476718442..6d506e58b3c 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/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
@@ -19,23 +19,24 @@ package
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.core;
import com.google.common.base.Splitter;
import org.antlr.v4.runtime.tree.ParseTree;
+import
org.apache.shardingsphere.data.pipeline.distsql.statement.updatable.AlterTransmissionRuleStatement;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.pojo.SourceTargetEntry;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationCheckStatusStatement;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationListStatement;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationRuleStatement;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationSourceStorageUnitsStatement;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationStatusStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.CheckMigrationStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.CommitMigrationStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.DropMigrationCheckStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.MigrateTableStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.RegisterMigrationSourceStorageUnitStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.RollbackMigrationStatement;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationCheckStatusStatement;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationListStatement;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationRuleStatement;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationSourceStorageUnitsStatement;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.queryable.ShowMigrationStatusStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.StartMigrationCheckStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.StartMigrationStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.StopMigrationCheckStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.StopMigrationStatement;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.updatable.UnregisterMigrationSourceStorageUnitStatement;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.statement.pojo.SourceTargetEntry;
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;
@@ -78,7 +79,6 @@ 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.updatable.AlterTransmissionRuleStatement;
import
org.apache.shardingsphere.infra.database.core.metadata.database.enums.QuoteCharacter;
import org.apache.shardingsphere.infra.datanode.DataNode;
import org.apache.shardingsphere.sql.parser.api.ASTNode;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/facade/MigrationDistSQLParserFacade.java
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/facade/MigrationDistSQLParserFacade.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/facade/MigrationDistSQLParserFacade.java
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/facade/MigrationDistSQLParserFacade.java
index 93f3a2ed3bb..eb66100131c 100644
---
a/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/facade/MigrationDistSQLParserFacade.java
+++
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/parser/facade/MigrationDistSQLParserFacade.java
@@ -17,10 +17,10 @@
package
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.facade;
+import
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.core.MigrationDistSQLLexer;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.core.MigrationDistSQLParser;
import
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.core.MigrationDistSQLStatementVisitor;
import org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade;
-import
org.apache.shardingsphere.data.pipeline.migration.distsql.parser.core.MigrationDistSQLLexer;
import org.apache.shardingsphere.sql.parser.api.ASTNode;
import org.apache.shardingsphere.sql.parser.api.parser.SQLLexer;
import org.apache.shardingsphere.sql.parser.api.parser.SQLParser;
diff --git
a/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
b/kernel/data-pipeline/scenario/migration/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
similarity index 100%
rename from
kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
rename to
kernel/data-pipeline/scenario/migration/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.DistSQLParserFacade
diff --git a/kernel/data-pipeline/distsql/pom.xml
b/kernel/data-pipeline/scenario/migration/distsql/pom.xml
similarity index 89%
copy from kernel/data-pipeline/distsql/pom.xml
copy to kernel/data-pipeline/scenario/migration/distsql/pom.xml
index 99da2439a70..45dc19cce82 100644
--- a/kernel/data-pipeline/distsql/pom.xml
+++ b/kernel/data-pipeline/scenario/migration/distsql/pom.xml
@@ -20,10 +20,10 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-distsql</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql</artifactId>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
diff --git a/kernel/data-pipeline/scenario/migration/pom.xml
b/kernel/data-pipeline/scenario/migration/distsql/statement/pom.xml
similarity index 80%
copy from kernel/data-pipeline/scenario/migration/pom.xml
copy to kernel/data-pipeline/scenario/migration/distsql/statement/pom.xml
index 2b8a819baec..5099148b9ab 100644
--- a/kernel/data-pipeline/scenario/migration/pom.xml
+++ b/kernel/data-pipeline/scenario/migration/distsql/statement/pom.xml
@@ -20,10 +20,10 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-scenario</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql</artifactId>
<version>5.5.3-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-statement</artifactId>
<name>${project.artifactId}</name>
<dependencies>
@@ -32,10 +32,5 @@
<artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-core</artifactId>
- <version>${project.version}</version>
- </dependency>
</dependencies>
</project>
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/MigrationRALStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/MigrationRALStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/MigrationRALStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/MigrationRALStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/pojo/SourceTargetEntry.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/pojo/SourceTargetEntry.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/pojo/SourceTargetEntry.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/pojo/SourceTargetEntry.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/QueryableMigrationRALStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/QueryableMigrationRALStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/QueryableMigrationRALStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/QueryableMigrationRALStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationCheckStatusStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationCheckStatusStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationCheckStatusStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationCheckStatusStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationListStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationListStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationListStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationListStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationRuleStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationRuleStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationRuleStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationRuleStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationSourceStorageUnitsStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationSourceStorageUnitsStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationSourceStorageUnitsStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationSourceStorageUnitsStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationStatusStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationStatusStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationStatusStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/queryable/ShowMigrationStatusStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CheckMigrationStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CheckMigrationStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CheckMigrationStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CheckMigrationStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CommitMigrationStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CommitMigrationStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CommitMigrationStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/CommitMigrationStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/DropMigrationCheckStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/DropMigrationCheckStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/DropMigrationCheckStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/DropMigrationCheckStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/MigrateTableStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/MigrateTableStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/MigrateTableStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/MigrateTableStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RegisterMigrationSourceStorageUnitStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RegisterMigrationSourceStorageUnitStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RegisterMigrationSourceStorageUnitStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RegisterMigrationSourceStorageUnitStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RollbackMigrationStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RollbackMigrationStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RollbackMigrationStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/RollbackMigrationStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationCheckStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationCheckStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationCheckStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationCheckStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StartMigrationStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationCheckStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationCheckStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationCheckStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationCheckStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/StopMigrationStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UnregisterMigrationSourceStorageUnitStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UnregisterMigrationSourceStorageUnitStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UnregisterMigrationSourceStorageUnitStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UnregisterMigrationSourceStorageUnitStatement.java
diff --git
a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UpdatableMigrationRALStatement.java
b/kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UpdatableMigrationRALStatement.java
similarity index 100%
rename from
kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UpdatableMigrationRALStatement.java
rename to
kernel/data-pipeline/scenario/migration/distsql/statement/src/main/java/org/apache/shardingsphere/data/pipeline/migration/distsql/statement/updatable/UpdatableMigrationRALStatement.java
diff --git a/kernel/data-pipeline/scenario/migration/pom.xml
b/kernel/data-pipeline/scenario/migration/pom.xml
index 2b8a819baec..58eeb0e24e3 100644
--- a/kernel/data-pipeline/scenario/migration/pom.xml
+++ b/kernel/data-pipeline/scenario/migration/pom.xml
@@ -24,18 +24,11 @@
<version>5.5.3-SNAPSHOT</version>
</parent>
<artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
+ <packaging>pom</packaging>
<name>${project.artifactId}</name>
- <dependencies>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-data-pipeline-core</artifactId>
- <version>${project.version}</version>
- </dependency>
- </dependencies>
+ <modules>
+ <module>core</module>
+ <module>distsql</module>
+ </modules>
</project>
diff --git a/proxy/backend/core/pom.xml b/proxy/backend/core/pom.xml
index 2e8004bff12..bbdb89956ab 100644
--- a/proxy/backend/core/pom.xml
+++ b/proxy/backend/core/pom.xml
@@ -104,22 +104,17 @@
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-scenario-consistency-check</artifactId>
+
<artifactId>shardingsphere-data-pipeline-distsql-handler</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-handler</artifactId>
+
<artifactId>shardingsphere-data-pipeline-cdc-distsql-handler</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-cdc-distsql-handler</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-handler</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
diff --git a/test/it/parser/pom.xml b/test/it/parser/pom.xml
index cb69fbfcc08..dc85d562df6 100644
--- a/test/it/parser/pom.xml
+++ b/test/it/parser/pom.xml
@@ -38,12 +38,12 @@
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-distsql-parser</artifactId>
+
<artifactId>shardingsphere-data-pipeline-cdc-distsql-parser</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-cdc-distsql-parser</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-distsql-parser</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
diff --git a/test/it/pipeline/pom.xml b/test/it/pipeline/pom.xml
index 30194939549..ae720684c06 100644
--- a/test/it/pipeline/pom.xml
+++ b/test/it/pipeline/pom.xml
@@ -44,7 +44,7 @@
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
-
<artifactId>shardingsphere-data-pipeline-scenario-migration</artifactId>
+
<artifactId>shardingsphere-data-pipeline-scenario-migration-core</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
