This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang 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 ddc48ee Add schedule basic modules and schedule-core module initial
commit (#13897)
ddc48ee is described below
commit ddc48ee9384d38b48fa9338a7171247284a0a4e7
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Thu Dec 2 14:46:43 2021 +0800
Add schedule basic modules and schedule-core module initial commit (#13897)
* Add schedule and cdc modules
* Add schedule core module
* Add cdc dialect dependency
* Add migration common module
* Add dependency for scaling
* Move ScalingExecutor to schedule-core module, rename to LifecycleExecutor
* Follow review suggestion
---
shardingsphere-kernel/pom.xml | 1 +
.../{ => shardingsphere-schedule}/pom.xml | 12 +++++-----
.../shardingsphere-cdc}/pom.xml | 11 ++++-----
.../shardingsphere-cdc-core}/pom.xml | 19 ++++++++-------
.../shardingsphere-cdc-dialect}/pom.xml | 12 +++++-----
.../shardingsphere-cdc-mysql}/pom.xml | 19 ++++++++-------
.../shardingsphere-cdc-opengauss}/pom.xml | 19 ++++++++-------
.../shardingsphere-cdc-postgresql}/pom.xml | 19 ++++++++-------
.../shardingsphere-migration-common}/pom.xml | 19 ++++++++-------
.../shardingsphere-schedule-core}/pom.xml | 12 +++-------
.../core/executor/AbstractLifecycleExecutor.java | 6 ++---
.../schedule/core/executor/LifecycleExecutor.java | 6 ++---
.../shardingsphere-scaling-core/pom.xml | 5 ++++
.../executor/dumper/AbstractInventoryDumper.java | 4 ++--
.../scaling/core/executor/dumper/Dumper.java | 4 ++--
.../core/executor/engine/ExecuteEngine.java | 28 +++++++++++-----------
.../core/executor/importer/AbstractImporter.java | 4 ++--
.../scaling/core/executor/importer/Importer.java | 4 ++--
.../executor/job/FinishedCheckJobExecutor.java | 4 ++--
.../core/executor/job/ScalingJobExecutor.java | 4 ++--
.../scaling/core/job/task/ScalingTask.java | 4 ++--
.../core/job/task/incremental/IncrementalTask.java | 4 ++--
.../core/job/task/inventory/InventoryTask.java | 4 ++--
.../core/executor/engine/ExecuteEngineTest.java | 6 ++---
.../shardingsphere-scaling-mysql/pom.xml | 5 ++++
.../mysql/component/MySQLIncrementalDumper.java | 4 ++--
.../shardingsphere-scaling-opengauss/pom.xml | 5 ++++
.../opengauss/component/OpenGaussWalDumper.java | 4 ++--
.../shardingsphere-scaling-postgresql/pom.xml | 5 ++++
.../postgresql/component/PostgreSQLWalDumper.java | 4 ++--
30 files changed, 138 insertions(+), 119 deletions(-)
diff --git a/shardingsphere-kernel/pom.xml b/shardingsphere-kernel/pom.xml
index 33cd6cf..ce0b0e5 100644
--- a/shardingsphere-kernel/pom.xml
+++ b/shardingsphere-kernel/pom.xml
@@ -33,5 +33,6 @@
<module>shardingsphere-single-table</module>
<module>shardingsphere-authority</module>
<module>shardingsphere-transaction</module>
+ <module>shardingsphere-schedule</module>
</modules>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/pom.xml
similarity index 83%
copy from shardingsphere-kernel/pom.xml
copy to shardingsphere-kernel/shardingsphere-schedule/pom.xml
index 33cd6cf..22889d2 100644
--- a/shardingsphere-kernel/pom.xml
+++ b/shardingsphere-kernel/shardingsphere-schedule/pom.xml
@@ -19,19 +19,19 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-kernel</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-schedule</artifactId>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
<modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
+ <module>shardingsphere-cdc</module>
+ <module>shardingsphere-schedule-core</module>
+ <module>shardingsphere-migration-common</module>
</modules>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/pom.xml
similarity index 84%
copy from shardingsphere-kernel/pom.xml
copy to shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/pom.xml
index 33cd6cf..48134cf 100644
--- a/shardingsphere-kernel/pom.xml
+++ b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/pom.xml
@@ -19,19 +19,18 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-schedule</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-cdc</artifactId>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
<modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
+ <module>shardingsphere-cdc-core</module>
+ <module>shardingsphere-cdc-dialect</module>
</modules>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/pom.xml
similarity index 77%
copy from shardingsphere-kernel/pom.xml
copy to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/pom.xml
index 33cd6cf..800066e 100644
--- a/shardingsphere-kernel/pom.xml
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-core/pom.xml
@@ -19,19 +19,20 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-cdc</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
- <packaging>pom</packaging>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-cdc-core</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
- </modules>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-schedule-core</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+ </dependencies>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/pom.xml
similarity index 83%
copy from shardingsphere-kernel/pom.xml
copy to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/pom.xml
index 33cd6cf..9e75364 100644
--- a/shardingsphere-kernel/pom.xml
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/pom.xml
@@ -19,19 +19,19 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-cdc</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-cdc-dialect</artifactId>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
<modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
+ <module>shardingsphere-cdc-mysql</module>
+ <module>shardingsphere-cdc-postgresql</module>
+ <module>shardingsphere-cdc-opengauss</module>
</modules>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-mysql/pom.xml
similarity index 77%
copy from shardingsphere-kernel/pom.xml
copy to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-mysql/pom.xml
index 33cd6cf..4d96c87 100644
--- a/shardingsphere-kernel/pom.xml
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-mysql/pom.xml
@@ -19,19 +19,20 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-cdc-dialect</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
- <packaging>pom</packaging>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-cdc-mysql</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
- </modules>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-cdc-core</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+ </dependencies>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-opengauss/pom.xml
similarity index 77%
copy from shardingsphere-kernel/pom.xml
copy to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-opengauss/pom.xml
index 33cd6cf..680205a 100644
--- a/shardingsphere-kernel/pom.xml
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-opengauss/pom.xml
@@ -19,19 +19,20 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-cdc-dialect</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
- <packaging>pom</packaging>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-cdc-opengauss</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
- </modules>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-cdc-core</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+ </dependencies>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-postgresql/pom.xml
similarity index 77%
copy from shardingsphere-kernel/pom.xml
copy to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-postgresql/pom.xml
index 33cd6cf..8209b92 100644
--- a/shardingsphere-kernel/pom.xml
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-cdc/shardingsphere-cdc-dialect/shardingsphere-cdc-postgresql/pom.xml
@@ -19,19 +19,20 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-cdc-dialect</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
- <packaging>pom</packaging>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-cdc-postgresql</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
- </modules>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-cdc-core</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+ </dependencies>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-migration-common/pom.xml
similarity index 77%
copy from shardingsphere-kernel/pom.xml
copy to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-migration-common/pom.xml
index 33cd6cf..7a26cd3 100644
--- a/shardingsphere-kernel/pom.xml
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-migration-common/pom.xml
@@ -19,19 +19,20 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-schedule</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
- <packaging>pom</packaging>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-migration-common</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
- </modules>
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-cdc-core</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
</project>
diff --git a/shardingsphere-kernel/pom.xml
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/pom.xml
similarity index 80%
copy from shardingsphere-kernel/pom.xml
copy to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/pom.xml
index 33cd6cf..d77cf94 100644
--- a/shardingsphere-kernel/pom.xml
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/pom.xml
@@ -19,19 +19,13 @@
<project xmlns="http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
- <modelVersion>4.0.0</modelVersion>
<parent>
+ <artifactId>shardingsphere-schedule</artifactId>
<groupId>org.apache.shardingsphere</groupId>
- <artifactId>shardingsphere</artifactId>
<version>5.0.1-SNAPSHOT</version>
</parent>
- <artifactId>shardingsphere-kernel</artifactId>
- <packaging>pom</packaging>
+ <modelVersion>4.0.0</modelVersion>
+ <artifactId>shardingsphere-schedule-core</artifactId>
<name>${project.artifactId}</name>
- <modules>
- <module>shardingsphere-single-table</module>
- <module>shardingsphere-authority</module>
- <module>shardingsphere-transaction</module>
- </modules>
</project>
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/AbstractScalingExecutor.java
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core/executor/AbstractLifecycleExecutor.java
similarity index 87%
rename from
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/AbstractScalingExecutor.java
rename to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core/executor/AbstractLifecycleExecutor.java
index ea9bdd4..e0621b3 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/AbstractScalingExecutor.java
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core/executor/AbstractLifecycleExecutor.java
@@ -15,18 +15,18 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.scaling.core.executor;
+package org.apache.shardingsphere.schedule.core.executor;
import lombok.AccessLevel;
import lombok.Getter;
import lombok.Setter;
/**
- * Abstract scaling executor.
+ * Abstract lifecycle executor.
*/
@Getter
@Setter
-public abstract class AbstractScalingExecutor implements ScalingExecutor {
+public abstract class AbstractLifecycleExecutor implements LifecycleExecutor {
@Setter(AccessLevel.PROTECTED)
@Getter(AccessLevel.PROTECTED)
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/ScalingExecutor.java
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core/executor/LifecycleExecutor.java
similarity index 87%
rename from
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/ScalingExecutor.java
rename to
shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core/executor/LifecycleExecutor.java
index aded982..e8906ae 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/ScalingExecutor.java
+++
b/shardingsphere-kernel/shardingsphere-schedule/shardingsphere-schedule-core/src/main/java/org/apache/shardingsphere/schedule/core/executor/LifecycleExecutor.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.scaling.core.executor;
+package org.apache.shardingsphere.schedule.core.executor;
/**
- * Scaling executor.
+ * Lifecycle executor.
*/
-public interface ScalingExecutor extends Runnable {
+public interface LifecycleExecutor extends Runnable {
/**
* Start run execute.
diff --git a/shardingsphere-scaling/shardingsphere-scaling-core/pom.xml
b/shardingsphere-scaling/shardingsphere-scaling-core/pom.xml
index 277c78f..b197512 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-core/pom.xml
+++ b/shardingsphere-scaling/shardingsphere-scaling-core/pom.xml
@@ -31,6 +31,11 @@
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-migration-common</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-sharding-core</artifactId>
<version>${project.version}</version>
</dependency>
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/AbstractInventoryDumper.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/AbstractInventoryDumper.java
index 91e0102..e7d3e82 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/AbstractInventoryDumper.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/AbstractInventoryDumper.java
@@ -34,7 +34,7 @@ import
org.apache.shardingsphere.scaling.core.common.record.Record;
import
org.apache.shardingsphere.scaling.core.config.InventoryDumperConfiguration;
import
org.apache.shardingsphere.scaling.core.config.datasource.ScalingDataSourceConfiguration;
import
org.apache.shardingsphere.scaling.core.config.datasource.StandardJDBCDataSourceConfiguration;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import org.apache.shardingsphere.scaling.core.job.position.FinishedPosition;
import org.apache.shardingsphere.scaling.core.job.position.PlaceholderPosition;
import org.apache.shardingsphere.scaling.core.job.position.PrimaryKeyPosition;
@@ -50,7 +50,7 @@ import java.sql.SQLException;
* Abstract JDBC dumper implement.
*/
@Slf4j
-public abstract class AbstractInventoryDumper extends AbstractScalingExecutor
implements InventoryDumper {
+public abstract class AbstractInventoryDumper extends
AbstractLifecycleExecutor implements InventoryDumper {
@Getter(AccessLevel.PROTECTED)
private final InventoryDumperConfiguration inventoryDumperConfig;
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/Dumper.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/Dumper.java
index bdfd7d6..f40d74f 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/Dumper.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/dumper/Dumper.java
@@ -18,12 +18,12 @@
package org.apache.shardingsphere.scaling.core.executor.dumper;
import org.apache.shardingsphere.scaling.core.common.channel.Channel;
-import org.apache.shardingsphere.scaling.core.executor.ScalingExecutor;
+import org.apache.shardingsphere.schedule.core.executor.LifecycleExecutor;
/**
* Dumper interface.
*/
-public interface Dumper extends ScalingExecutor {
+public interface Dumper extends LifecycleExecutor {
/**
* Set channel.
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngine.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngine.java
index 1583429..e746de0 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngine.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngine.java
@@ -25,7 +25,7 @@ import com.google.common.util.concurrent.MoreExecutors;
import lombok.AccessLevel;
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.infra.executor.kernel.thread.ExecutorThreadFactoryBuilder;
-import org.apache.shardingsphere.scaling.core.executor.ScalingExecutor;
+import org.apache.shardingsphere.schedule.core.executor.LifecycleExecutor;
import javax.annotation.ParametersAreNonnullByDefault;
import java.util.ArrayList;
@@ -64,38 +64,38 @@ public final class ExecuteEngine {
}
/**
- * Submit a {@code ScalingExecutor} without callback to execute.
+ * Submit a {@code LifecycleExecutor} without callback to execute.
*
- * @param scalingExecutor scaling executor
+ * @param lifecycleExecutor lifecycle executor
* @return execute future
*/
- public Future<?> submit(final ScalingExecutor scalingExecutor) {
- return executorService.submit(scalingExecutor);
+ public Future<?> submit(final LifecycleExecutor lifecycleExecutor) {
+ return executorService.submit(lifecycleExecutor);
}
/**
- * Submit a {@code ScalingExecutor} with callback {@code ExecuteCallback}
to execute.
+ * Submit a {@code LifecycleExecutor} with callback {@code
ExecuteCallback} to execute.
*
- * @param scalingExecutor scaling executor
+ * @param lifecycleExecutor lifecycle executor
* @param executeCallback execute callback
* @return execute future
*/
- public Future<?> submit(final ScalingExecutor scalingExecutor, final
ExecuteCallback executeCallback) {
- ListenableFuture<?> result = executorService.submit(scalingExecutor);
+ public Future<?> submit(final LifecycleExecutor lifecycleExecutor, final
ExecuteCallback executeCallback) {
+ ListenableFuture<?> result = executorService.submit(lifecycleExecutor);
Futures.addCallback(result, new
ExecuteFutureCallback<>(executeCallback), executorService);
return result;
}
/**
- * Submit a collection of {@code ScalingExecutor} with callback {@code
ExecuteCallback} to execute.
+ * Submit a collection of {@code LifecycleExecutor} with callback {@code
ExecuteCallback} to execute.
*
- * @param scalingExecutors scaling executor
+ * @param lifecycleExecutors lifecycle executor
* @param executeCallback execute callback
* @return execute future of all
*/
- public Future<?> submitAll(final Collection<? extends ScalingExecutor>
scalingExecutors, final ExecuteCallback executeCallback) {
- Collection<ListenableFuture<?>> listenableFutures = new
ArrayList<>(scalingExecutors.size());
- for (ScalingExecutor each : scalingExecutors) {
+ public Future<?> submitAll(final Collection<? extends LifecycleExecutor>
lifecycleExecutors, final ExecuteCallback executeCallback) {
+ Collection<ListenableFuture<?>> listenableFutures = new
ArrayList<>(lifecycleExecutors.size());
+ for (LifecycleExecutor each : lifecycleExecutors) {
ListenableFuture<?> listenableFuture =
executorService.submit(each);
listenableFutures.add(listenableFuture);
}
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/AbstractImporter.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/AbstractImporter.java
index 6991240..f810793 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/AbstractImporter.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/AbstractImporter.java
@@ -32,7 +32,7 @@ import
org.apache.shardingsphere.scaling.core.common.record.Record;
import org.apache.shardingsphere.scaling.core.common.record.RecordUtil;
import
org.apache.shardingsphere.scaling.core.common.sqlbuilder.ScalingSQLBuilder;
import org.apache.shardingsphere.scaling.core.config.ImporterConfiguration;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import org.apache.shardingsphere.scaling.core.util.ThreadUtil;
import javax.sql.DataSource;
@@ -48,7 +48,7 @@ import java.util.stream.Collectors;
* Abstract importer.
*/
@Slf4j
-public abstract class AbstractImporter extends AbstractScalingExecutor
implements Importer {
+public abstract class AbstractImporter extends AbstractLifecycleExecutor
implements Importer {
private static final DataRecordMerger MERGER = new DataRecordMerger();
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/Importer.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/Importer.java
index 423fca4..0068631 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/Importer.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/importer/Importer.java
@@ -18,12 +18,12 @@
package org.apache.shardingsphere.scaling.core.executor.importer;
import org.apache.shardingsphere.scaling.core.common.channel.Channel;
-import org.apache.shardingsphere.scaling.core.executor.ScalingExecutor;
+import org.apache.shardingsphere.schedule.core.executor.LifecycleExecutor;
/**
* Importer.
*/
-public interface Importer extends ScalingExecutor {
+public interface Importer extends LifecycleExecutor {
/**
* Set channel.
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/FinishedCheckJobExecutor.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/FinishedCheckJobExecutor.java
index 23b763f..76b8bc1 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/FinishedCheckJobExecutor.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/FinishedCheckJobExecutor.java
@@ -23,14 +23,14 @@ import
org.apache.shardingsphere.elasticjob.lite.api.bootstrap.impl.ScheduleJobB
import org.apache.shardingsphere.scaling.core.api.ScalingAPIFactory;
import
org.apache.shardingsphere.scaling.core.api.ScalingClusterAutoSwitchAlgorithm;
import org.apache.shardingsphere.scaling.core.config.ScalingContext;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import org.apache.shardingsphere.scaling.core.job.FinishedCheckJob;
/**
* Finished check job executor.
*/
@Slf4j
-public final class FinishedCheckJobExecutor extends AbstractScalingExecutor {
+public final class FinishedCheckJobExecutor extends AbstractLifecycleExecutor {
private static final String JOB_NAME = "_finished_check";
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/ScalingJobExecutor.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/ScalingJobExecutor.java
index daf7253..5abcf37 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/ScalingJobExecutor.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/executor/job/ScalingJobExecutor.java
@@ -25,7 +25,7 @@ import
org.apache.shardingsphere.mode.repository.cluster.listener.DataChangedEve
import org.apache.shardingsphere.infra.yaml.engine.YamlEngine;
import org.apache.shardingsphere.scaling.core.api.ScalingAPIFactory;
import org.apache.shardingsphere.scaling.core.common.constant.ScalingConstant;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import org.apache.shardingsphere.scaling.core.job.ScalingJob;
import org.apache.shardingsphere.scaling.core.job.schedule.JobSchedulerCenter;
@@ -37,7 +37,7 @@ import java.util.regex.Pattern;
* Scaling job executor.
*/
@Slf4j
-public final class ScalingJobExecutor extends AbstractScalingExecutor {
+public final class ScalingJobExecutor extends AbstractLifecycleExecutor {
private static final Pattern CONFIG_PATTERN =
Pattern.compile(ScalingConstant.SCALING_ROOT + "/(\\d+)/config");
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/ScalingTask.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/ScalingTask.java
index 4f32590..4c30341 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/ScalingTask.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/ScalingTask.java
@@ -17,13 +17,13 @@
package org.apache.shardingsphere.scaling.core.job.task;
-import org.apache.shardingsphere.scaling.core.executor.ScalingExecutor;
+import org.apache.shardingsphere.schedule.core.executor.LifecycleExecutor;
import org.apache.shardingsphere.scaling.core.job.progress.Progress;
/**
* Scaling task interface.
*/
-public interface ScalingTask extends ScalingExecutor {
+public interface ScalingTask extends LifecycleExecutor {
/**
* Get task id.
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/incremental/IncrementalTask.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/incremental/IncrementalTask.java
index 52f4918..12b7f86 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/incremental/IncrementalTask.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/incremental/IncrementalTask.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.scaling.core.common.record.Record;
import org.apache.shardingsphere.scaling.core.config.DumperConfiguration;
import org.apache.shardingsphere.scaling.core.config.ImporterConfiguration;
import org.apache.shardingsphere.scaling.core.config.ScalingContext;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import org.apache.shardingsphere.scaling.core.executor.dumper.Dumper;
import org.apache.shardingsphere.scaling.core.executor.dumper.DumperFactory;
import org.apache.shardingsphere.scaling.core.executor.engine.ExecuteCallback;
@@ -48,7 +48,7 @@ import java.util.concurrent.Future;
*/
@Slf4j
@ToString(exclude = {"dataSourceManager", "dumper", "progress"})
-public final class IncrementalTask extends AbstractScalingExecutor implements
ScalingTask {
+public final class IncrementalTask extends AbstractLifecycleExecutor
implements ScalingTask {
@Getter
private final String taskId;
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/inventory/InventoryTask.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/inventory/InventoryTask.java
index 4b8714c..ef86653 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/inventory/InventoryTask.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/task/inventory/InventoryTask.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.scaling.core.common.record.Record;
import org.apache.shardingsphere.scaling.core.config.ImporterConfiguration;
import
org.apache.shardingsphere.scaling.core.config.InventoryDumperConfiguration;
import org.apache.shardingsphere.scaling.core.config.ScalingContext;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import org.apache.shardingsphere.scaling.core.executor.dumper.Dumper;
import org.apache.shardingsphere.scaling.core.executor.dumper.DumperFactory;
import org.apache.shardingsphere.scaling.core.executor.engine.ExecuteCallback;
@@ -46,7 +46,7 @@ import java.util.concurrent.Future;
*/
@Slf4j
@ToString(exclude = {"dataSourceManager", "dumper"})
-public final class InventoryTask extends AbstractScalingExecutor implements
ScalingTask {
+public final class InventoryTask extends AbstractLifecycleExecutor implements
ScalingTask {
@Getter
private final String taskId;
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngineTest.java
b/shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngineTest.java
index 5f03a3da..9cea0fd 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngineTest.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/executor/engine/ExecuteEngineTest.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.scaling.core.executor.engine;
-import org.apache.shardingsphere.scaling.core.executor.ScalingExecutor;
+import org.apache.shardingsphere.schedule.core.executor.LifecycleExecutor;
import org.apache.shardingsphere.scaling.core.util.ThreadUtil;
import org.junit.Test;
@@ -70,9 +70,9 @@ public final class ExecuteEngineTest {
};
}
- private ScalingExecutor mockScalingExecutor() {
+ private LifecycleExecutor mockScalingExecutor() {
- return new ScalingExecutor() {
+ return new LifecycleExecutor() {
@Override
public void run() {
ThreadUtil.sleep(100L);
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/pom.xml
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/pom.xml
index 1b2f302..0b132e8 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/pom.xml
+++
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/pom.xml
@@ -31,6 +31,11 @@
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-cdc-mysql</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-scaling-core</artifactId>
<version>${project.version}</version>
</dependency>
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/MySQLIncrementalDumper.java
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/MySQLIncrementalDumper.java
index 3e9710a..3d527f9 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/MySQLIncrementalDumper.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/component/MySQLIncrementalDumper.java
@@ -32,7 +32,7 @@ import
org.apache.shardingsphere.scaling.core.common.record.PlaceholderRecord;
import org.apache.shardingsphere.scaling.core.common.record.Record;
import org.apache.shardingsphere.scaling.core.config.DumperConfiguration;
import
org.apache.shardingsphere.scaling.core.config.datasource.StandardJDBCDataSourceConfiguration;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import
org.apache.shardingsphere.scaling.core.executor.dumper.IncrementalDumper;
import org.apache.shardingsphere.scaling.core.job.position.PlaceholderPosition;
import org.apache.shardingsphere.scaling.core.job.position.ScalingPosition;
@@ -62,7 +62,7 @@ import java.util.stream.Collectors;
* MySQL incremental dumper.
*/
@Slf4j
-public final class MySQLIncrementalDumper extends AbstractScalingExecutor
implements IncrementalDumper {
+public final class MySQLIncrementalDumper extends AbstractLifecycleExecutor
implements IncrementalDumper {
private static final Map<String, ValueHandler> VALUE_HANDLER_MAP;
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/pom.xml
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/pom.xml
index 40bd80c..e3eb099 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/pom.xml
+++
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/pom.xml
@@ -31,6 +31,11 @@
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-cdc-opengauss</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-scaling-postgresql</artifactId>
<version>${project.version}</version>
</dependency>
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/src/main/java/org/apache/shardingsphere/scaling/opengauss/component/OpenGaussWalDumper.java
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/src/main/java/org/apache/shardingsphere/scaling/opengauss/component/OpenGaussWalDumper.java
index 8ad7003..58ddb62 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/src/main/java/org/apache/shardingsphere/scaling/opengauss/component/OpenGaussWalDumper.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-opengauss/src/main/java/org/apache/shardingsphere/scaling/opengauss/component/OpenGaussWalDumper.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.scaling.core.common.record.DataRecord;
import org.apache.shardingsphere.scaling.core.common.record.Record;
import org.apache.shardingsphere.scaling.core.config.DumperConfiguration;
import
org.apache.shardingsphere.scaling.core.config.datasource.StandardJDBCDataSourceConfiguration;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import
org.apache.shardingsphere.scaling.core.executor.dumper.IncrementalDumper;
import org.apache.shardingsphere.scaling.core.job.position.ScalingPosition;
import org.apache.shardingsphere.scaling.core.util.ThreadUtil;
@@ -52,7 +52,7 @@ import java.sql.SQLException;
* OpenGauss WAL dumper.
*/
@Slf4j
-public final class OpenGaussWalDumper extends AbstractScalingExecutor
implements IncrementalDumper {
+public final class OpenGaussWalDumper extends AbstractLifecycleExecutor
implements IncrementalDumper {
private final WalPosition walPosition;
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/pom.xml
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/pom.xml
index 64b218d..91e57ce 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/pom.xml
+++
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/pom.xml
@@ -31,6 +31,11 @@
<dependencies>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
+ <artifactId>shardingsphere-cdc-postgresql</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.shardingsphere</groupId>
<artifactId>shardingsphere-scaling-core</artifactId>
<version>${project.version}</version>
</dependency>
diff --git
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/component/PostgreSQLWalDumper.java
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/component/PostgreSQLWalDumper.java
index 415f86b..1068162 100644
---
a/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/component/PostgreSQLWalDumper.java
+++
b/shardingsphere-scaling/shardingsphere-scaling-dialect/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/component/PostgreSQLWalDumper.java
@@ -24,7 +24,7 @@ import
org.apache.shardingsphere.scaling.core.common.exception.ScalingTaskExecut
import org.apache.shardingsphere.scaling.core.common.record.Record;
import org.apache.shardingsphere.scaling.core.config.DumperConfiguration;
import
org.apache.shardingsphere.scaling.core.config.datasource.StandardJDBCDataSourceConfiguration;
-import org.apache.shardingsphere.scaling.core.executor.AbstractScalingExecutor;
+import
org.apache.shardingsphere.schedule.core.executor.AbstractLifecycleExecutor;
import
org.apache.shardingsphere.scaling.core.executor.dumper.IncrementalDumper;
import org.apache.shardingsphere.scaling.core.job.position.ScalingPosition;
import org.apache.shardingsphere.scaling.core.util.ThreadUtil;
@@ -48,7 +48,7 @@ import java.sql.SQLException;
* PostgreSQL WAL dumper.
*/
@Slf4j
-public final class PostgreSQLWalDumper extends AbstractScalingExecutor
implements IncrementalDumper {
+public final class PostgreSQLWalDumper extends AbstractLifecycleExecutor
implements IncrementalDumper {
private final WalPosition walPosition;
