From 727215d68e35e2444bcbc47825c8ed0a0e42bb02 Mon Sep 17 00:00:00 2001 From: zhangliang Date: Mon, 6 Nov 2023 15:09:19 +0800 Subject: [PATCH] Move PipelineLifecycleRunnable --- .../shardingsphere/data/pipeline/api/ingest/dumper/Dumper.java | 2 +- .../api/{executor => runnable}/PipelineLifecycleRunnable.java | 2 +- .../common/execute/AbstractPipelineLifecycleRunnable.java | 2 +- .../data/pipeline/common/execute/ExecuteEngine.java | 2 +- .../shardingsphere/data/pipeline/core/importer/Importer.java | 2 +- .../data/pipeline/common/execute/ExecuteEngineTest.java | 2 +- .../consistencycheck/task/ConsistencyCheckTasksRunner.java | 2 +- 7 files changed, 7 insertions(+), 7 deletions(-) rename kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/{executor => runnable}/PipelineLifecycleRunnable.java (94%) diff --git a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/dumper/Dumper.java b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/dumper/Dumper.java index 8fe270d2bae39..dc12667cd5848 100644 --- a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/dumper/Dumper.java +++ b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/ingest/dumper/Dumper.java @@ -17,7 +17,7 @@ package org.apache.shardingsphere.data.pipeline.api.ingest.dumper; -import org.apache.shardingsphere.data.pipeline.api.executor.PipelineLifecycleRunnable; +import org.apache.shardingsphere.data.pipeline.api.runnable.PipelineLifecycleRunnable; /** * Dumper interface. diff --git a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/executor/PipelineLifecycleRunnable.java b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/runnable/PipelineLifecycleRunnable.java similarity index 94% rename from kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/executor/PipelineLifecycleRunnable.java rename to kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/runnable/PipelineLifecycleRunnable.java index e0bafe65eacb4..4b0233f2f97b2 100644 --- a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/executor/PipelineLifecycleRunnable.java +++ b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/runnable/PipelineLifecycleRunnable.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.shardingsphere.data.pipeline.api.executor; +package org.apache.shardingsphere.data.pipeline.api.runnable; /** * Pipeline lifecycle runnable. diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/AbstractPipelineLifecycleRunnable.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/AbstractPipelineLifecycleRunnable.java index 52f427ff5212e..51dcacb213a74 100644 --- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/AbstractPipelineLifecycleRunnable.java +++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/AbstractPipelineLifecycleRunnable.java @@ -18,7 +18,7 @@ package org.apache.shardingsphere.data.pipeline.common.execute; import lombok.extern.slf4j.Slf4j; -import org.apache.shardingsphere.data.pipeline.api.executor.PipelineLifecycleRunnable; +import org.apache.shardingsphere.data.pipeline.api.runnable.PipelineLifecycleRunnable; import java.sql.SQLException; import java.time.Instant; diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngine.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngine.java index a6cf5cab917ae..eb6a1b4ea62d6 100644 --- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngine.java +++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngine.java @@ -20,7 +20,7 @@ import lombok.AccessLevel; import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; -import org.apache.shardingsphere.data.pipeline.api.executor.PipelineLifecycleRunnable; +import org.apache.shardingsphere.data.pipeline.api.runnable.PipelineLifecycleRunnable; import org.apache.shardingsphere.data.pipeline.core.exception.PipelineInternalException; import org.apache.shardingsphere.infra.executor.kernel.thread.ExecutorThreadFactoryBuilder; diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/Importer.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/Importer.java index 7f480709ed219..2217f39a38ab1 100644 --- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/Importer.java +++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/importer/Importer.java @@ -17,7 +17,7 @@ package org.apache.shardingsphere.data.pipeline.core.importer; -import org.apache.shardingsphere.data.pipeline.api.executor.PipelineLifecycleRunnable; +import org.apache.shardingsphere.data.pipeline.api.runnable.PipelineLifecycleRunnable; /** * Importer. diff --git a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngineTest.java b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngineTest.java index 8d273b4fe6d3e..99c26bf500579 100644 --- a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngineTest.java +++ b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/common/execute/ExecuteEngineTest.java @@ -19,7 +19,7 @@ import lombok.RequiredArgsConstructor; import lombok.SneakyThrows; -import org.apache.shardingsphere.data.pipeline.api.executor.PipelineLifecycleRunnable; +import org.apache.shardingsphere.data.pipeline.api.runnable.PipelineLifecycleRunnable; import org.junit.jupiter.api.Test; import org.mockito.internal.configuration.plugins.Plugins; diff --git a/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/task/ConsistencyCheckTasksRunner.java b/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/task/ConsistencyCheckTasksRunner.java index 4e51ee8096bcd..4034b3d6056b9 100644 --- a/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/task/ConsistencyCheckTasksRunner.java +++ b/kernel/data-pipeline/scenario/consistencycheck/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/consistencycheck/task/ConsistencyCheckTasksRunner.java @@ -20,7 +20,7 @@ import lombok.Getter; import lombok.extern.slf4j.Slf4j; import org.apache.shardingsphere.data.pipeline.common.execute.AbstractPipelineLifecycleRunnable; -import org.apache.shardingsphere.data.pipeline.api.executor.PipelineLifecycleRunnable; +import org.apache.shardingsphere.data.pipeline.api.runnable.PipelineLifecycleRunnable; import org.apache.shardingsphere.data.pipeline.common.config.job.PipelineJobConfiguration; import org.apache.shardingsphere.data.pipeline.common.execute.ExecuteCallback; import org.apache.shardingsphere.data.pipeline.common.execute.ExecuteEngine;