You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by su...@apache.org on 2022/11/17 12:54:33 UTC
[shardingsphere] branch master updated: Add pipeline-distsql module and move classes (#22243)
This is an automated email from the ASF dual-hosted git repository.
sunnianjun 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 d51481e00d9 Add pipeline-distsql module and move classes (#22243)
d51481e00d9 is described below
commit d51481e00d95df390f82534c7cabcaffa71a8e96
Author: Hongsheng Zhong <zh...@apache.org>
AuthorDate: Thu Nov 17 20:54:23 2022 +0800
Add pipeline-distsql module and move classes (#22243)
* Move migration classes from sharding-distsql module to pipeline-distsql module
* Depend on pipeline-distsql-handler module in proxy
* Move ResourceSegmentsConverter from sharding-distsql-handler module to distsql-statement module
* Test pass
---
agent/plugins/metrics/api/pom.xml | 6 +++++
distsql/statement/pom.xml | 5 ++++
.../converter/ResourceSegmentsConverter.java | 2 +-
.../converter/ResourceSegmentsConverterTest.java | 2 +-
...dingsphere.infra.distsql.query.DistSQLResultSet | 5 ----
...engine.spi.FeaturedDistSQLStatementParserFacade | 1 -
.../data-pipeline/distsql/handler}/pom.xml | 26 ++++++++-----------
...ShowMigrationCheckAlgorithmsQueryResultSet.java | 0
.../ShowMigrationCheckStatusQueryResultSet.java | 0
.../ShowMigrationJobStatusQueryResultSet.java | 0
.../query/ShowMigrationListQueryResultSet.java | 0
...wMigrationSourceStorageUnitsQueryResultSet.java | 0
.../handler/update/CheckMigrationJobUpdater.java | 0
.../handler/update/CommitMigrationUpdater.java | 0
.../handler/update/MigrateTableUpdater.java | 0
.../RegisterMigrationSourceStorageUnitUpdater.java | 2 +-
.../handler/update/RollbackMigrationUpdater.java | 0
.../handler/update/StartMigrationCheckUpdater.java | 0
.../handler/update/StartMigrationUpdater.java | 0
.../handler/update/StopMigrationCheckUpdater.java | 0
.../handler/update/StopMigrationUpdater.java | 0
...nregisterMigrationSourceStorageUnitUpdater.java | 0
...dingsphere.infra.distsql.query.DistSQLResultSet | 7 +++--
....shardingsphere.infra.distsql.update.RALUpdater | 0
.../InputJobRateLimitAlgorithmFixture.java | 0
.../OutputJobRateLimitAlgorithmFixture.java | 0
...ta.pipeline.spi.ratelimit.JobRateLimitAlgorithm | 0
.../data-pipeline/distsql/parser}/pom.xml | 30 +++++++++++++++-------
.../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 | 0
.../core/MigrationDistSQLStatementVisitor.java | 0
.../MigrationDistSQLStatementParserFacade.java | 0
...engine.spi.FeaturedDistSQLStatementParserFacade | 1 -
kernel/data-pipeline/{ => distsql}/pom.xml | 12 ++++-----
.../data-pipeline/distsql}/statement/pom.xml | 6 ++---
.../distsql/statement/CheckMigrationStatement.java | 0
.../statement/CommitMigrationStatement.java | 0
.../distsql/statement/MigrateTableStatement.java | 0
...egisterMigrationSourceStorageUnitStatement.java | 0
.../statement/RollbackMigrationStatement.java | 0
.../ShowMigrationCheckAlgorithmsStatement.java | 0
.../ShowMigrationCheckStatusStatement.java | 0
.../statement/ShowMigrationListStatement.java | 0
.../ShowMigrationSourceStorageUnitsStatement.java | 0
.../statement/ShowMigrationStatusStatement.java | 0
.../statement/StartMigrationCheckStatement.java | 0
.../distsql/statement/StartMigrationStatement.java | 0
.../statement/StopMigrationCheckStatement.java | 0
.../distsql/statement/StopMigrationStatement.java | 0
...egisterMigrationSourceStorageUnitStatement.java | 0
kernel/data-pipeline/pom.xml | 1 +
proxy/backend/pom.xml | 5 ++++
.../resource/AlterStorageUnitBackendHandler.java | 2 +-
.../RegisterStorageUnitBackendHandler.java | 2 +-
test/parser/pom.xml | 10 ++++++++
63 files changed, 77 insertions(+), 48 deletions(-)
diff --git a/agent/plugins/metrics/api/pom.xml b/agent/plugins/metrics/api/pom.xml
index 3bb007b47df..d547ac5b4d3 100644
--- a/agent/plugins/metrics/api/pom.xml
+++ b/agent/plugins/metrics/api/pom.xml
@@ -46,6 +46,12 @@
<version>${project.version}</version>
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
+ <version>${project.version}</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
<build>
diff --git a/distsql/statement/pom.xml b/distsql/statement/pom.xml
index 62678f99639..351ec390dfa 100644
--- a/distsql/statement/pom.xml
+++ b/distsql/statement/pom.xml
@@ -28,6 +28,11 @@
<name>${project.artifactId}</name>
<dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-infra-common</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-sql-parser-statement</artifactId>
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/converter/ResourceSegmentsConverter.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/segment/converter/ResourceSegmentsConverter.java
similarity index 97%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/converter/ResourceSegmentsConverter.java
rename to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/segment/converter/ResourceSegmentsConverter.java
index 2d0c86b3f2d..827b9df4e9b 100644
--- a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/sharding/distsql/handler/converter/ResourceSegmentsConverter.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/segment/converter/ResourceSegmentsConverter.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.sharding.distsql.handler.converter;
+package org.apache.shardingsphere.distsql.parser.segment.converter;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
diff --git a/features/sharding/distsql/handler/src/test/java/org/apache/shardingsphere/sharding/distsql/handler/converter/ResourceSegmentsConverterTest.java b/distsql/statement/src/test/java/org/apache/shardingsphere/distsql/parser/segment/converter/ResourceSegmentsConverterTest.java
similarity index 97%
rename from features/sharding/distsql/handler/src/test/java/org/apache/shardingsphere/sharding/distsql/handler/converter/ResourceSegmentsConverterTest.java
rename to distsql/statement/src/test/java/org/apache/shardingsphere/distsql/parser/segment/converter/ResourceSegmentsConverterTest.java
index 17761b99333..b56d91e60dc 100644
--- a/features/sharding/distsql/handler/src/test/java/org/apache/shardingsphere/sharding/distsql/handler/converter/ResourceSegmentsConverterTest.java
+++ b/distsql/statement/src/test/java/org/apache/shardingsphere/distsql/parser/segment/converter/ResourceSegmentsConverterTest.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.sharding.distsql.handler.converter;
+package org.apache.shardingsphere.distsql.parser.segment.converter;
import org.apache.shardingsphere.distsql.parser.segment.DataSourceSegment;
import org.apache.shardingsphere.distsql.parser.segment.HostnameAndPortBasedDataSourceSegment;
diff --git a/features/sharding/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet b/features/sharding/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
index 0380113a8e3..10ea572c03d 100644
--- a/features/sharding/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
+++ b/features/sharding/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
@@ -23,11 +23,6 @@ org.apache.shardingsphere.sharding.distsql.handler.query.ShardingAuditorsQueryRe
org.apache.shardingsphere.sharding.distsql.handler.query.ShardingTableNodesQueryResultSet
org.apache.shardingsphere.sharding.distsql.handler.query.ShardingKeyGeneratorsQueryResultSet
org.apache.shardingsphere.sharding.distsql.handler.query.DefaultShardingStrategyQueryResultSet
-org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationCheckStatusQueryResultSet
-org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationListQueryResultSet
-org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationJobStatusQueryResultSet
-org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationCheckAlgorithmsQueryResultSet
-org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationSourceStorageUnitsQueryResultSet
org.apache.shardingsphere.sharding.distsql.handler.query.UnusedShardingAlgorithmsQueryResultSet
org.apache.shardingsphere.sharding.distsql.handler.query.UnusedShardingKeyGeneratorsQueryResultSet
org.apache.shardingsphere.sharding.distsql.handler.query.UnusedShardingAuditorsQueryResultSet
diff --git a/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade b/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
index 2340ed50572..d28e042f287 100644
--- a/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
+++ b/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
@@ -16,4 +16,3 @@
#
org.apache.shardingsphere.sharding.distsql.parser.facade.ShardingDistSQLStatementParserFacade
-org.apache.shardingsphere.migration.distsql.parser.facade.MigrationDistSQLStatementParserFacade
diff --git a/agent/plugins/metrics/api/pom.xml b/kernel/data-pipeline/distsql/handler/pom.xml
similarity index 75%
copy from agent/plugins/metrics/api/pom.xml
copy to kernel/data-pipeline/distsql/handler/pom.xml
index 3bb007b47df..cc28720131f 100644
--- a/agent/plugins/metrics/api/pom.xml
+++ b/kernel/data-pipeline/distsql/handler/pom.xml
@@ -21,38 +21,34 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-agent-plugin-metrics</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql</artifactId>
<version>5.2.2-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-agent-metrics-api</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql-handler</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-agent-core</artifactId>
+ <artifactId>shardingsphere-data-pipeline-core</artifactId>
<version>${project.version}</version>
- <scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-infra-route</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
<version>${project.version}</version>
- <scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-sharding-distsql-statement</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql-parser</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-test-common</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>
</dependencies>
-
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-jar-plugin</artifactId>
- </plugin>
- </plugins>
- </build>
</project>
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsQueryResultSet.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsQueryResultSet.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsQueryResultSet.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckAlgorithmsQueryResultSet.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusQueryResultSet.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusQueryResultSet.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusQueryResultSet.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationCheckStatusQueryResultSet.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusQueryResultSet.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusQueryResultSet.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusQueryResultSet.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationJobStatusQueryResultSet.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListQueryResultSet.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListQueryResultSet.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListQueryResultSet.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationListQueryResultSet.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsQueryResultSet.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsQueryResultSet.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsQueryResultSet.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/query/ShowMigrationSourceStorageUnitsQueryResultSet.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CheckMigrationJobUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CheckMigrationJobUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CheckMigrationJobUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CheckMigrationJobUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CommitMigrationUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CommitMigrationUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CommitMigrationUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/CommitMigrationUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/MigrateTableUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
similarity index 97%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
index ec4f784890f..d161628f854 100644
--- a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
+++ b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RegisterMigrationSourceStorageUnitUpdater.java
@@ -22,6 +22,7 @@ import org.apache.shardingsphere.data.pipeline.api.PipelineJobPublicAPIFactory;
import org.apache.shardingsphere.distsql.parser.segment.DataSourceSegment;
import org.apache.shardingsphere.distsql.parser.segment.HostnameAndPortBasedDataSourceSegment;
import org.apache.shardingsphere.distsql.parser.segment.URLBasedDataSourceSegment;
+import org.apache.shardingsphere.distsql.parser.segment.converter.ResourceSegmentsConverter;
import org.apache.shardingsphere.infra.database.type.DatabaseType;
import org.apache.shardingsphere.infra.database.type.DatabaseTypeEngine;
import org.apache.shardingsphere.infra.datasource.props.DataSourceProperties;
@@ -30,7 +31,6 @@ import org.apache.shardingsphere.infra.distsql.update.RALUpdater;
import org.apache.shardingsphere.infra.util.exception.ShardingSpherePreconditions;
import org.apache.shardingsphere.infra.util.exception.external.sql.type.generic.UnsupportedSQLOperationException;
import org.apache.shardingsphere.migration.distsql.statement.RegisterMigrationSourceStorageUnitStatement;
-import org.apache.shardingsphere.sharding.distsql.handler.converter.ResourceSegmentsConverter;
import java.util.ArrayList;
import java.util.List;
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RollbackMigrationUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RollbackMigrationUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RollbackMigrationUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/RollbackMigrationUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationCheckUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationCheckUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationCheckUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationCheckUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StartMigrationUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationCheckUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationCheckUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationCheckUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationCheckUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/StopMigrationUpdater.java
diff --git a/features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java b/kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java
similarity index 100%
rename from features/sharding/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java
rename to kernel/data-pipeline/distsql/handler/src/main/java/org/apache/shardingsphere/migration/distsql/handler/update/UnregisterMigrationSourceStorageUnitUpdater.java
diff --git a/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
similarity index 61%
copy from features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
copy to kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
index 2340ed50572..6ba6a5de27d 100644
--- a/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
+++ b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.query.DistSQLResultSet
@@ -15,5 +15,8 @@
# limitations under the License.
#
-org.apache.shardingsphere.sharding.distsql.parser.facade.ShardingDistSQLStatementParserFacade
-org.apache.shardingsphere.migration.distsql.parser.facade.MigrationDistSQLStatementParserFacade
+org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationCheckStatusQueryResultSet
+org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationListQueryResultSet
+org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationJobStatusQueryResultSet
+org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationCheckAlgorithmsQueryResultSet
+org.apache.shardingsphere.migration.distsql.handler.query.ShowMigrationSourceStorageUnitsQueryResultSet
diff --git a/features/sharding/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater b/kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater
similarity index 100%
rename from features/sharding/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater
rename to kernel/data-pipeline/distsql/handler/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.distsql.update.RALUpdater
diff --git a/features/sharding/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/InputJobRateLimitAlgorithmFixture.java b/kernel/data-pipeline/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/InputJobRateLimitAlgorithmFixture.java
similarity index 100%
rename from features/sharding/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/InputJobRateLimitAlgorithmFixture.java
rename to kernel/data-pipeline/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/InputJobRateLimitAlgorithmFixture.java
diff --git a/features/sharding/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/OutputJobRateLimitAlgorithmFixture.java b/kernel/data-pipeline/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/OutputJobRateLimitAlgorithmFixture.java
similarity index 100%
rename from features/sharding/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/OutputJobRateLimitAlgorithmFixture.java
rename to kernel/data-pipeline/distsql/handler/src/test/java/org/apache/shardingsphere/data/pipeline/spi/ratelimit/OutputJobRateLimitAlgorithmFixture.java
diff --git a/features/sharding/distsql/handler/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.ratelimit.JobRateLimitAlgorithm b/kernel/data-pipeline/distsql/handler/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.ratelimit.JobRateLimitAlgorithm
similarity index 100%
rename from features/sharding/distsql/handler/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.ratelimit.JobRateLimitAlgorithm
rename to kernel/data-pipeline/distsql/handler/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.ratelimit.JobRateLimitAlgorithm
diff --git a/agent/plugins/metrics/api/pom.xml b/kernel/data-pipeline/distsql/parser/pom.xml
similarity index 62%
copy from agent/plugins/metrics/api/pom.xml
copy to kernel/data-pipeline/distsql/parser/pom.xml
index 3bb007b47df..4810cd97333 100644
--- a/agent/plugins/metrics/api/pom.xml
+++ b/kernel/data-pipeline/distsql/parser/pom.xml
@@ -21,37 +21,49 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-agent-plugin-metrics</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql</artifactId>
<version>5.2.2-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-agent-metrics-api</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql-parser</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-agent-core</artifactId>
+ <artifactId>shardingsphere-sql-parser-spi</artifactId>
<version>${project.version}</version>
- <scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-infra-route</artifactId>
+ <artifactId>shardingsphere-distsql-parser</artifactId>
<version>${project.version}</version>
- <scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-sharding-distsql-statement</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
<version>${project.version}</version>
- <scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
- <artifactId>maven-jar-plugin</artifactId>
+ <groupId>org.antlr</groupId>
+ <artifactId>antlr4-maven-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>antlr-migration</id>
+ <goals>
+ <goal>antlr4</goal>
+ </goals>
+ <configuration>
+ <sourceDirectory>src/main/antlr4/migration/</sourceDirectory>
+ <libDirectory>src/main/antlr4/imports/migration/</libDirectory>
+ <listener>false</listener>
+ <visitor>true</visitor>
+ </configuration>
+ </execution>
+ </executions>
</plugin>
</plugins>
</build>
diff --git a/features/sharding/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Alphabet.g4
diff --git a/features/sharding/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/BaseRule.g4
diff --git a/features/sharding/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Keyword.g4
diff --git a/features/sharding/distsql/parser/src/main/antlr4/imports/migration/Literals.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Literals.g4
diff --git a/features/sharding/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RALStatement.g4
diff --git a/features/sharding/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/RQLStatement.g4
diff --git a/features/sharding/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/imports/migration/Symbol.g4
diff --git a/features/sharding/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4 b/kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
similarity index 100%
rename from features/sharding/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
rename to kernel/data-pipeline/distsql/parser/src/main/antlr4/migration/org/apache/shardingsphere/distsql/parser/autogen/MigrationDistSQLStatement.g4
diff --git a/features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLLexer.java b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLLexer.java
similarity index 100%
rename from features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLLexer.java
rename to kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLLexer.java
diff --git a/features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLParser.java b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLParser.java
similarity index 100%
rename from features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLParser.java
rename to kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLParser.java
diff --git a/features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
similarity index 100%
rename from features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
rename to kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/core/MigrationDistSQLStatementVisitor.java
diff --git a/features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/facade/MigrationDistSQLStatementParserFacade.java b/kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/facade/MigrationDistSQLStatementParserFacade.java
similarity index 100%
rename from features/sharding/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/facade/MigrationDistSQLStatementParserFacade.java
rename to kernel/data-pipeline/distsql/parser/src/main/java/org/apache/shardingsphere/migration/distsql/parser/facade/MigrationDistSQLStatementParserFacade.java
diff --git a/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade b/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
similarity index 90%
copy from features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
copy to kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
index 2340ed50572..b3799653425 100644
--- a/features/sharding/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
+++ b/kernel/data-pipeline/distsql/parser/src/main/resources/META-INF/services/org.apache.shardingsphere.distsql.parser.engine.spi.FeaturedDistSQLStatementParserFacade
@@ -15,5 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.sharding.distsql.parser.facade.ShardingDistSQLStatementParserFacade
org.apache.shardingsphere.migration.distsql.parser.facade.MigrationDistSQLStatementParserFacade
diff --git a/kernel/data-pipeline/pom.xml b/kernel/data-pipeline/distsql/pom.xml
similarity index 83%
copy from kernel/data-pipeline/pom.xml
copy to kernel/data-pipeline/distsql/pom.xml
index 6790adaefcd..939e39a7a76 100644
--- a/kernel/data-pipeline/pom.xml
+++ b/kernel/data-pipeline/distsql/pom.xml
@@ -21,18 +21,16 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-kernel</artifactId>
+ <artifactId>shardingsphere-data-pipeline</artifactId>
<version>5.2.2-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-data-pipeline</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql</artifactId>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
<modules>
- <module>api</module>
- <module>core</module>
- <module>dialect</module>
- <module>scenario</module>
- <module>cdc</module>
+ <module>statement</module>
+ <module>parser</module>
+ <module>handler</module>
</modules>
</project>
diff --git a/distsql/statement/pom.xml b/kernel/data-pipeline/distsql/statement/pom.xml
similarity index 87%
copy from distsql/statement/pom.xml
copy to kernel/data-pipeline/distsql/statement/pom.xml
index 62678f99639..85175dd04c4 100644
--- a/distsql/statement/pom.xml
+++ b/kernel/data-pipeline/distsql/statement/pom.xml
@@ -21,16 +21,16 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-distsql</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql</artifactId>
<version>5.2.2-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-distsql-statement</artifactId>
+ <artifactId>shardingsphere-data-pipeline-distsql-statement</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere-sql-parser-statement</artifactId>
+ <artifactId>shardingsphere-distsql-statement</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java
diff --git a/features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java
similarity index 100%
rename from features/sharding/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java
rename to kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java
diff --git a/kernel/data-pipeline/pom.xml b/kernel/data-pipeline/pom.xml
index 6790adaefcd..69cf2ec0fae 100644
--- a/kernel/data-pipeline/pom.xml
+++ b/kernel/data-pipeline/pom.xml
@@ -32,6 +32,7 @@
<module>api</module>
<module>core</module>
<module>dialect</module>
+ <module>distsql</module>
<module>scenario</module>
<module>cdc</module>
</modules>
diff --git a/proxy/backend/pom.xml b/proxy/backend/pom.xml
index 7fba29fdd08..0aa76c20e62 100644
--- a/proxy/backend/pom.xml
+++ b/proxy/backend/pom.xml
@@ -193,6 +193,11 @@
<artifactId>shardingsphere-data-pipeline-scenario</artifactId>
<version>${project.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-data-pipeline-distsql-handler</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-sql-federation-core</artifactId>
diff --git a/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/AlterStorageUnitBackendHandler.java b/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/AlterStorageUnitBackendHandler.java
index d3b832c83c8..f445ee6524c 100644
--- a/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/AlterStorageUnitBackendHandler.java
+++ b/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/AlterStorageUnitBackendHandler.java
@@ -21,6 +21,7 @@ import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.distsql.parser.segment.DataSourceSegment;
import org.apache.shardingsphere.distsql.parser.segment.HostnameAndPortBasedDataSourceSegment;
import org.apache.shardingsphere.distsql.parser.segment.URLBasedDataSourceSegment;
+import org.apache.shardingsphere.distsql.parser.segment.converter.ResourceSegmentsConverter;
import org.apache.shardingsphere.distsql.parser.statement.rdl.alter.AlterStorageUnitStatement;
import org.apache.shardingsphere.infra.database.metadata.url.JdbcUrl;
import org.apache.shardingsphere.infra.database.metadata.url.StandardJdbcUrlParser;
@@ -38,7 +39,6 @@ import org.apache.shardingsphere.proxy.backend.handler.DatabaseRequiredBackendHa
import org.apache.shardingsphere.proxy.backend.response.header.ResponseHeader;
import org.apache.shardingsphere.proxy.backend.response.header.update.UpdateResponseHeader;
import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
-import org.apache.shardingsphere.sharding.distsql.handler.converter.ResourceSegmentsConverter;
import javax.sql.DataSource;
import java.sql.SQLException;
diff --git a/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/RegisterStorageUnitBackendHandler.java b/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/RegisterStorageUnitBackendHandler.java
index 8737eb240aa..dfdec722686 100644
--- a/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/RegisterStorageUnitBackendHandler.java
+++ b/proxy/backend/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/RegisterStorageUnitBackendHandler.java
@@ -19,6 +19,7 @@ package org.apache.shardingsphere.proxy.backend.handler.distsql.rdl.resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.distsql.parser.segment.DataSourceSegment;
+import org.apache.shardingsphere.distsql.parser.segment.converter.ResourceSegmentsConverter;
import org.apache.shardingsphere.distsql.parser.statement.rdl.create.RegisterStorageUnitStatement;
import org.apache.shardingsphere.infra.database.type.DatabaseType;
import org.apache.shardingsphere.infra.datasource.props.DataSourceProperties;
@@ -35,7 +36,6 @@ import org.apache.shardingsphere.proxy.backend.session.ConnectionSession;
import org.apache.shardingsphere.readwritesplitting.api.ReadwriteSplittingRuleConfiguration;
import org.apache.shardingsphere.readwritesplitting.api.rule.ReadwriteSplittingDataSourceRuleConfiguration;
import org.apache.shardingsphere.readwritesplitting.rule.ReadwriteSplittingRule;
-import org.apache.shardingsphere.sharding.distsql.handler.converter.ResourceSegmentsConverter;
import java.sql.SQLException;
import java.util.ArrayList;
diff --git a/test/parser/pom.xml b/test/parser/pom.xml
index 447a03456e4..5980c1940dc 100644
--- a/test/parser/pom.xml
+++ b/test/parser/pom.xml
@@ -70,6 +70,16 @@
<artifactId>shardingsphere-distsql-statement</artifactId>
<version>${project.version}</version>
</dependency>
+ <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-distsql-parser</artifactId>
+ <version>${project.version}</version>
+ </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-distsql-parser</artifactId>