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-elasticjob.git
The following commit(s) were added to refs/heads/master by this push:
new 98e487763 Move ElasticJobListener to api module (#2343)
98e487763 is described below
commit 98e4877635db74fa7cf3fbf18fa7c670ecf5bff4
Author: Liang Zhang <[email protected]>
AuthorDate: Mon Oct 30 23:36:15 2023 +0800
Move ElasticJobListener to api module (#2343)
---
.../elasticjob/spi/{ => executor}/JobItemExecutor.java | 6 +++---
.../elasticjob/spi/{ => executor}/param/JobRuntimeService.java | 2 +-
.../elasticjob/spi/{ => executor}/param/ShardingContext.java | 2 +-
.../elasticjob/spi/{ => executor}/type/ClassedJobItemExecutor.java | 4 ++--
.../elasticjob/spi/{ => executor}/type/TypedJobItemExecutor.java | 4 ++--
.../shardingsphere/elasticjob/spi}/listener/ElasticJobListener.java | 3 ++-
.../elasticjob/spi/listener/param}/ShardingContexts.java | 4 ++--
.../apache/shardingsphere/elasticjob/annotation/job/CustomJob.java | 2 +-
.../elasticjob/annotation/job/impl/SimpleTestJob.java | 2 +-
.../elasticjob/spi/listener/param}/ShardingContextsTest.java | 6 +++---
.../elasticjob/dataflow/executor/DataflowJobExecutor.java | 6 +++---
.../apache/shardingsphere/elasticjob/dataflow/job/DataflowJob.java | 2 +-
...rdingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor} | 0
.../elasticjob/dataflow/executor/DataflowJobExecutorTest.java | 4 ++--
.../shardingsphere/elasticjob/http/executor/HttpJobExecutor.java | 6 +++---
...hardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor} | 0
.../elasticjob/http/executor/HttpJobExecutorTest.java | 4 ++--
.../elasticjob/script/executor/ScriptJobExecutor.java | 6 +++---
...hardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor} | 0
.../shardingsphere/elasticjob/script/ScriptJobExecutorTest.java | 4 ++--
.../elasticjob/simple/executor/SimpleJobExecutor.java | 6 +++---
.../org/apache/shardingsphere/elasticjob/simple/job/SimpleJob.java | 2 +-
...rdingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor} | 0
.../elasticjob/simple/executor/SimpleJobExecutorTest.java | 2 +-
.../apache/shardingsphere/elasticjob/simple/job/FooSimpleJob.java | 2 +-
.../elasticjob/example/job/dataflow/JavaDataflowJob.java | 2 +-
.../elasticjob/example/job/dataflow/SpringDataflowJob.java | 2 +-
.../elasticjob/example/job/simple/JavaOccurErrorJob.java | 2 +-
.../shardingsphere/elasticjob/example/job/simple/JavaSimpleJob.java | 2 +-
.../elasticjob/example/job/simple/SpringSimpleJob.java | 2 +-
.../elasticjob/example/job/SpringBootDataflowJob.java | 2 +-
.../example/job/SpringBootOccurErrorNoticeDingtalkJob.java | 2 +-
.../elasticjob/example/job/SpringBootOccurErrorNoticeEmailJob.java | 2 +-
.../elasticjob/example/job/SpringBootOccurErrorNoticeWechatJob.java | 2 +-
.../shardingsphere/elasticjob/example/job/SpringBootSimpleJob.java | 2 +-
.../elasticjob/kernel/internal/executor/ElasticJobExecutor.java | 6 +++---
.../elasticjob/kernel/internal/executor/JobFacade.java | 6 +++---
.../kernel/internal/executor/JobJobRuntimeServiceImpl.java | 2 +-
.../kernel/internal/executor/item/JobItemExecutorFactory.java | 4 ++--
.../kernel/internal/guarantee/GuaranteeListenerManager.java | 2 +-
.../elasticjob/kernel/internal/guarantee/GuaranteeService.java | 2 +-
.../elasticjob/kernel/internal/listener/ListenerManager.java | 2 +-
.../elasticjob/kernel/internal/schedule/JobScheduler.java | 2 +-
.../elasticjob/kernel/internal/setup/SetUpFacade.java | 2 +-
.../kernel/internal/sharding/ExecutionContextService.java | 2 +-
.../elasticjob/kernel/internal/sharding/ExecutionService.java | 2 +-
.../kernel/listener/AbstractDistributeOnceElasticJobListener.java | 4 ++--
.../kernel/api/listener/DistributeOnceElasticJobListenerTest.java | 2 +-
.../api/listener/fixture/TestDistributeOnceElasticJobListener.java | 2 +-
.../kernel/api/listener/fixture/TestElasticJobListener.java | 4 ++--
.../elasticjob/kernel/fixture/executor/ClassedFooJobExecutor.java | 6 +++---
.../elasticjob/kernel/fixture/executor/TypedFooJobExecutor.java | 6 +++---
.../elasticjob/kernel/fixture/job/DetailedFooJob.java | 2 +-
.../apache/shardingsphere/elasticjob/kernel/fixture/job/FooJob.java | 2 +-
.../elasticjob/kernel/internal/executor/ElasticJobExecutorTest.java | 4 ++--
.../elasticjob/kernel/internal/executor/JobFacadeTest.java | 2 +-
.../kernel/internal/guarantee/GuaranteeListenerManagerTest.java | 2 +-
.../elasticjob/kernel/internal/guarantee/GuaranteeServiceTest.java | 2 +-
.../kernel/internal/sharding/ExecutionContextServiceTest.java | 2 +-
.../elasticjob/kernel/internal/sharding/ExecutionServiceTest.java | 2 +-
...rdingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor} | 0
...hardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor} | 0
...pache.shardingsphere.elasticjob.spi.listener.ElasticJobListener} | 0
.../spring/boot/job/executor/CustomClassedJobExecutor.java | 6 +++---
.../elasticjob/spring/boot/job/executor/PrintJobExecutor.java | 6 +++---
.../elasticjob/spring/boot/job/fixture/job/CustomJob.java | 2 +-
.../spring/boot/job/fixture/job/impl/AnnotationCustomJob.java | 2 +-
.../elasticjob/spring/boot/job/fixture/job/impl/CustomTestJob.java | 2 +-
.../spring/boot/job/fixture/listener/LogElasticJobListener.java | 4 ++--
.../spring/boot/job/fixture/listener/NoopElasticJobListener.java | 4 ++--
...rdingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor} | 0
...hardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor} | 0
...pache.shardingsphere.elasticjob.spi.listener.ElasticJobListener} | 0
.../shardingsphere/elasticjob/spring/core/util/TargetJob.java | 2 +-
.../elasticjob/spring/namespace/fixture/job/DataflowElasticJob.java | 2 +-
.../spring/namespace/fixture/job/FooSimpleElasticJob.java | 2 +-
.../namespace/fixture/job/annotation/AnnotationSimpleJob.java | 2 +-
.../spring/namespace/fixture/job/ref/RefFooDataflowElasticJob.java | 2 +-
.../spring/namespace/fixture/job/ref/RefFooSimpleElasticJob.java | 2 +-
.../spring/namespace/fixture/listener/SimpleCglibListener.java | 4 ++--
.../namespace/fixture/listener/SimpleJdkDynamicProxyListener.java | 4 ++--
.../spring/namespace/fixture/listener/SimpleListener.java | 4 ++--
.../spring/namespace/fixture/listener/SimpleOnceListener.java | 2 +-
...pache.shardingsphere.elasticjob.spi.listener.ElasticJobListener} | 0
.../elasticjob/test/e2e/annotation/fixture/AnnotationSimpleJob.java | 2 +-
.../test/e2e/annotation/fixture/AnnotationUnShardingJob.java | 2 +-
.../test/e2e/raw/fixture/executor/E2EFixtureJobExecutor.java | 6 +++---
.../elasticjob/test/e2e/raw/fixture/job/E2EFixtureJob.java | 2 +-
.../elasticjob/test/e2e/raw/fixture/job/E2EFixtureJobImpl.java | 2 +-
.../raw/fixture/listener/DistributeOnceE2EFixtureJobListener.java | 2 +-
.../test/e2e/raw/fixture/listener/E2EFixtureJobListener.java | 4 ++--
...rdingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor} | 0
...pache.shardingsphere.elasticjob.spi.listener.ElasticJobListener} | 0
93 files changed, 123 insertions(+), 122 deletions(-)
diff --git
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/JobItemExecutor.java
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/JobItemExecutor.java
similarity index 86%
rename from
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/JobItemExecutor.java
rename to
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/JobItemExecutor.java
index 5e1ead8f1..e78c97aeb 100644
---
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/JobItemExecutor.java
+++
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/JobItemExecutor.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.spi;
+package org.apache.shardingsphere.elasticjob.spi.executor;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
/**
* Job item executor.
diff --git
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/param/JobRuntimeService.java
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/param/JobRuntimeService.java
similarity index 93%
rename from
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/param/JobRuntimeService.java
rename to
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/param/JobRuntimeService.java
index a09ddd8c9..35538aae5 100644
---
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/param/JobRuntimeService.java
+++
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/param/JobRuntimeService.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.spi.param;
+package org.apache.shardingsphere.elasticjob.spi.executor.param;
/**
* Job runtime service.
diff --git
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/param/ShardingContext.java
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/param/ShardingContext.java
similarity index 95%
rename from
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/param/ShardingContext.java
rename to
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/param/ShardingContext.java
index fe89ac016..a3f94167c 100644
---
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/param/ShardingContext.java
+++
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/param/ShardingContext.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.spi.param;
+package org.apache.shardingsphere.elasticjob.spi.executor.param;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/type/ClassedJobItemExecutor.java
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/type/ClassedJobItemExecutor.java
similarity index 90%
rename from
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/type/ClassedJobItemExecutor.java
rename to
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/type/ClassedJobItemExecutor.java
index 643348685..319618ecb 100644
---
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/type/ClassedJobItemExecutor.java
+++
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/type/ClassedJobItemExecutor.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.spi.type;
+package org.apache.shardingsphere.elasticjob.spi.executor.type;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.JobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.JobItemExecutor;
import org.apache.shardingsphere.infra.spi.annotation.SingletonSPI;
/**
diff --git
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/type/TypedJobItemExecutor.java
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/type/TypedJobItemExecutor.java
similarity index 89%
rename from
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/type/TypedJobItemExecutor.java
rename to
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/type/TypedJobItemExecutor.java
index c5c816c03..1d2c278fd 100644
---
a/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/type/TypedJobItemExecutor.java
+++
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/executor/type/TypedJobItemExecutor.java
@@ -15,10 +15,10 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.spi.type;
+package org.apache.shardingsphere.elasticjob.spi.executor.type;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.JobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.JobItemExecutor;
import org.apache.shardingsphere.infra.spi.annotation.SingletonSPI;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPI;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ElasticJobListener.java
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/listener/ElasticJobListener.java
similarity index 91%
rename from
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ElasticJobListener.java
rename to
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/listener/ElasticJobListener.java
index e92d72e2d..6d4cec342 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ElasticJobListener.java
+++
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/listener/ElasticJobListener.java
@@ -15,8 +15,9 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.kernel.infra.listener;
+package org.apache.shardingsphere.elasticjob.spi.listener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPI;
/**
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ShardingContexts.java
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/listener/param/ShardingContexts.java
similarity index 94%
rename from
kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ShardingContexts.java
rename to
api/src/main/java/org/apache/shardingsphere/elasticjob/spi/listener/param/ShardingContexts.java
index aef13ca19..aa9604868 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ShardingContexts.java
+++
b/api/src/main/java/org/apache/shardingsphere/elasticjob/spi/listener/param/ShardingContexts.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.kernel.infra.listener;
+package org.apache.shardingsphere.elasticjob.spi.listener.param;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.Setter;
import lombok.ToString;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import java.io.Serializable;
import java.util.Map;
diff --git
a/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/CustomJob.java
b/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/CustomJob.java
index febffd8d5..cd2f29ebd 100644
---
a/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/CustomJob.java
+++
b/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/CustomJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.annotation.job;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
public interface CustomJob extends ElasticJob {
diff --git
a/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/impl/SimpleTestJob.java
b/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/impl/SimpleTestJob.java
index 5e18ef55c..340a0fccd 100644
---
a/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/impl/SimpleTestJob.java
+++
b/api/src/test/java/org/apache/shardingsphere/elasticjob/annotation/job/impl/SimpleTestJob.java
@@ -21,7 +21,7 @@ import
org.apache.shardingsphere.elasticjob.annotation.ElasticJobConfiguration;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobProp;
import
org.apache.shardingsphere.elasticjob.annotation.SimpleTracingConfigurationFactory;
import org.apache.shardingsphere.elasticjob.annotation.job.CustomJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
@ElasticJobConfiguration(
cron = "0/5 * * * * ?",
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ShardingContextsTest.java
b/api/src/test/java/org/apache/shardingsphere/elasticjob/spi/listener/param/ShardingContextsTest.java
similarity index 90%
rename from
kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ShardingContextsTest.java
rename to
api/src/test/java/org/apache/shardingsphere/elasticjob/spi/listener/param/ShardingContextsTest.java
index b906c08f1..f4d32bb32 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/infra/listener/ShardingContextsTest.java
+++
b/api/src/test/java/org/apache/shardingsphere/elasticjob/spi/listener/param/ShardingContextsTest.java
@@ -15,9 +15,9 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.elasticjob.kernel.infra.listener;
+package org.apache.shardingsphere.elasticjob.spi.listener.param;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.junit.jupiter.api.Test;
import java.util.HashMap;
@@ -41,7 +41,7 @@ class ShardingContextsTest {
}
private ShardingContexts createShardingContexts() {
- Map<Integer, String> map = new HashMap<>(2, 1);
+ Map<Integer, String> map = new HashMap<>(2, 1F);
map.put(0, "A");
map.put(1, "B");
return new ShardingContexts("fake_task_id", "test_job", 2, "", map);
diff --git
a/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutor.java
b/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutor.java
index 96745d8b8..f3b1d3806 100644
---
a/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutor.java
+++
b/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutor.java
@@ -18,11 +18,11 @@
package org.apache.shardingsphere.elasticjob.dataflow.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.dataflow.job.DataflowJob;
import
org.apache.shardingsphere.elasticjob.dataflow.props.DataflowJobProperties;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor;
import java.util.List;
diff --git
a/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/job/DataflowJob.java
b/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/job/DataflowJob.java
index e63989514..a8009ead2 100644
---
a/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/job/DataflowJob.java
+++
b/ecosystem/executor/dataflow/src/main/java/org/apache/shardingsphere/elasticjob/dataflow/job/DataflowJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.dataflow.job;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import java.util.List;
diff --git
a/ecosystem/executor/dataflow/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
b/ecosystem/executor/dataflow/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
similarity index 100%
rename from
ecosystem/executor/dataflow/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
rename to
ecosystem/executor/dataflow/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
diff --git
a/ecosystem/executor/dataflow/src/test/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutorTest.java
b/ecosystem/executor/dataflow/src/test/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutorTest.java
index a9981957b..439efa5d9 100644
---
a/ecosystem/executor/dataflow/src/test/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutorTest.java
+++
b/ecosystem/executor/dataflow/src/test/java/org/apache/shardingsphere/elasticjob/dataflow/executor/DataflowJobExecutorTest.java
@@ -18,10 +18,10 @@
package org.apache.shardingsphere.elasticjob.dataflow.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.dataflow.job.DataflowJob;
import
org.apache.shardingsphere.elasticjob.dataflow.props.DataflowJobProperties;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
diff --git
a/ecosystem/executor/http/src/main/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutor.java
b/ecosystem/executor/http/src/main/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutor.java
index 94aaa551b..9d913920c 100644
---
a/ecosystem/executor/http/src/main/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutor.java
+++
b/ecosystem/executor/http/src/main/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutor.java
@@ -21,9 +21,9 @@ import com.google.common.base.Strings;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor;
import org.apache.shardingsphere.elasticjob.http.pojo.HttpParam;
import org.apache.shardingsphere.elasticjob.http.props.HttpJobProperties;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobConfigurationException;
diff --git
a/ecosystem/executor/http/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
b/ecosystem/executor/http/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
similarity index 100%
rename from
ecosystem/executor/http/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
rename to
ecosystem/executor/http/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
diff --git
a/ecosystem/executor/http/src/test/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutorTest.java
b/ecosystem/executor/http/src/test/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutorTest.java
index 1d5261996..346cf1543 100644
---
a/ecosystem/executor/http/src/test/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutorTest.java
+++
b/ecosystem/executor/http/src/test/java/org/apache/shardingsphere/elasticjob/http/executor/HttpJobExecutorTest.java
@@ -19,8 +19,8 @@ package org.apache.shardingsphere.elasticjob.http.executor;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
import
org.apache.shardingsphere.elasticjob.http.executor.fixture.InternalController;
import org.apache.shardingsphere.elasticjob.http.props.HttpJobProperties;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobConfigurationException;
diff --git
a/ecosystem/executor/script/src/main/java/org/apache/shardingsphere/elasticjob/script/executor/ScriptJobExecutor.java
b/ecosystem/executor/script/src/main/java/org/apache/shardingsphere/elasticjob/script/executor/ScriptJobExecutor.java
index ded2ddefc..cd6177dde 100644
---
a/ecosystem/executor/script/src/main/java/org/apache/shardingsphere/elasticjob/script/executor/ScriptJobExecutor.java
+++
b/ecosystem/executor/script/src/main/java/org/apache/shardingsphere/elasticjob/script/executor/ScriptJobExecutor.java
@@ -22,9 +22,9 @@ import org.apache.commons.exec.CommandLine;
import org.apache.commons.exec.DefaultExecutor;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobConfigurationException;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobSystemException;
import org.apache.shardingsphere.elasticjob.kernel.infra.json.GsonFactory;
diff --git
a/ecosystem/executor/script/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
b/ecosystem/executor/script/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
similarity index 100%
rename from
ecosystem/executor/script/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
rename to
ecosystem/executor/script/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
diff --git
a/ecosystem/executor/script/src/test/java/org/apache/shardingsphere/elasticjob/script/ScriptJobExecutorTest.java
b/ecosystem/executor/script/src/test/java/org/apache/shardingsphere/elasticjob/script/ScriptJobExecutorTest.java
index 033a84b27..febe4f561 100644
---
a/ecosystem/executor/script/src/test/java/org/apache/shardingsphere/elasticjob/script/ScriptJobExecutorTest.java
+++
b/ecosystem/executor/script/src/test/java/org/apache/shardingsphere/elasticjob/script/ScriptJobExecutorTest.java
@@ -20,8 +20,8 @@ package org.apache.shardingsphere.elasticjob.script;
import org.apache.commons.exec.OS;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobConfigurationException;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobSystemException;
import org.apache.shardingsphere.elasticjob.script.executor.ScriptJobExecutor;
diff --git
a/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutor.java
b/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutor.java
index 5c9b087a2..7ff8134aa 100644
---
a/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutor.java
+++
b/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutor.java
@@ -18,9 +18,9 @@
package org.apache.shardingsphere.elasticjob.simple.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
/**
diff --git
a/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/job/SimpleJob.java
b/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/job/SimpleJob.java
index 3c8ed6cd9..de6005ca1 100644
---
a/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/job/SimpleJob.java
+++
b/ecosystem/executor/simple/src/main/java/org/apache/shardingsphere/elasticjob/simple/job/SimpleJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.simple.job;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
/**
* Simple job.
diff --git
a/ecosystem/executor/simple/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
b/ecosystem/executor/simple/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
similarity index 100%
rename from
ecosystem/executor/simple/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
rename to
ecosystem/executor/simple/src/main/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
diff --git
a/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutorTest.java
b/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutorTest.java
index 6520ddd11..dba7f87ec 100644
---
a/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutorTest.java
+++
b/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/executor/SimpleJobExecutorTest.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.simple.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
import org.apache.shardingsphere.elasticjob.simple.job.FooSimpleJob;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import org.junit.jupiter.api.BeforeEach;
diff --git
a/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/job/FooSimpleJob.java
b/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/job/FooSimpleJob.java
index 8088292d4..e314e7dd1 100644
---
a/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/job/FooSimpleJob.java
+++
b/ecosystem/executor/simple/src/test/java/org/apache/shardingsphere/elasticjob/simple/job/FooSimpleJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.simple.job;
import lombok.Getter;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
@Getter
public final class FooSimpleJob implements SimpleJob {
diff --git
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/JavaDataflowJob.java
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/JavaDataflowJob.java
index 4eb6b7db3..08f20d187 100644
---
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/JavaDataflowJob.java
+++
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/JavaDataflowJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job.dataflow;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.dataflow.job.DataflowJob;
import org.apache.shardingsphere.elasticjob.example.fixture.entity.Foo;
import
org.apache.shardingsphere.elasticjob.example.fixture.repository.FooRepository;
diff --git
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/SpringDataflowJob.java
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/SpringDataflowJob.java
index ad3718537..e6c01aa5e 100644
---
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/SpringDataflowJob.java
+++
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/dataflow/SpringDataflowJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job.dataflow;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.dataflow.job.DataflowJob;
import org.apache.shardingsphere.elasticjob.example.fixture.entity.Foo;
import
org.apache.shardingsphere.elasticjob.example.fixture.repository.FooRepository;
diff --git
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaOccurErrorJob.java
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaOccurErrorJob.java
index bb983273c..3bc494e70 100644
---
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaOccurErrorJob.java
+++
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaOccurErrorJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job.simple;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
public final class JavaOccurErrorJob implements SimpleJob {
diff --git
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaSimpleJob.java
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaSimpleJob.java
index 481c4b9e6..5310c7d6e 100644
---
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaSimpleJob.java
+++
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/JavaSimpleJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job.simple;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import org.apache.shardingsphere.elasticjob.example.fixture.entity.Foo;
import
org.apache.shardingsphere.elasticjob.example.fixture.repository.FooRepository;
diff --git
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/SpringSimpleJob.java
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/SpringSimpleJob.java
index ef23d4dc7..bf2ccaae8 100644
---
a/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/SpringSimpleJob.java
+++
b/examples/elasticjob-example-jobs/src/main/java/org/apache/shardingsphere/elasticjob/example/job/simple/SpringSimpleJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job.simple;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import org.apache.shardingsphere.elasticjob.example.fixture.entity.Foo;
import
org.apache.shardingsphere.elasticjob.example.fixture.repository.FooRepository;
diff --git
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootDataflowJob.java
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootDataflowJob.java
index 830f0b3f2..c0eee4582 100644
---
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootDataflowJob.java
+++
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootDataflowJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.dataflow.job.DataflowJob;
import org.apache.shardingsphere.elasticjob.example.entity.Foo;
import org.apache.shardingsphere.elasticjob.example.repository.FooRepository;
diff --git
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeDingtalkJob.java
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeDingtalkJob.java
index f6b7961a2..a261595d4 100644
---
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeDingtalkJob.java
+++
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeDingtalkJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import org.springframework.stereotype.Component;
diff --git
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeEmailJob.java
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeEmailJob.java
index eeb3b25f2..f6b31f445 100644
---
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeEmailJob.java
+++
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeEmailJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import org.springframework.stereotype.Component;
diff --git
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeWechatJob.java
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeWechatJob.java
index 33b5c65ba..f11efc934 100644
---
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeWechatJob.java
+++
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootOccurErrorNoticeWechatJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import org.springframework.stereotype.Component;
diff --git
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootSimpleJob.java
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootSimpleJob.java
index aedb52911..13e6a8bc5 100644
---
a/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootSimpleJob.java
+++
b/examples/elasticjob-example-springboot/src/main/java/org/apache/shardingsphere/elasticjob/example/job/SpringBootSimpleJob.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.example.job;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.example.entity.Foo;
import org.apache.shardingsphere.elasticjob.example.repository.FooRepository;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutor.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutor.java
index 121080acd..26b323479 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutor.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutor.java
@@ -22,14 +22,14 @@ import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import
org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandler;
import
org.apache.shardingsphere.elasticjob.kernel.internal.executor.error.handler.JobErrorHandlerReloader;
-import org.apache.shardingsphere.elasticjob.spi.JobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.JobItemExecutor;
import
org.apache.shardingsphere.elasticjob.kernel.internal.executor.item.JobItemExecutorFactory;
-import org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor;
import
org.apache.shardingsphere.elasticjob.kernel.internal.executor.threadpool.ExecutorServiceReloader;
import org.apache.shardingsphere.elasticjob.kernel.infra.env.IpUtils;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.ExceptionUtils;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobExecutionEnvironmentException;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.internal.tracing.event.JobExecutionEvent;
import
org.apache.shardingsphere.elasticjob.kernel.internal.tracing.event.JobExecutionEvent.ExecutionSource;
import
org.apache.shardingsphere.elasticjob.kernel.internal.tracing.event.JobStatusTraceEvent.State;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacade.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacade.java
index 3f30a58c0..18c0b1cfd 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacade.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacade.java
@@ -21,8 +21,8 @@ import com.google.common.base.Strings;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobExecutionEnvironmentException;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.context.TaskContext;
import
org.apache.shardingsphere.elasticjob.kernel.internal.failover.FailoverService;
@@ -30,7 +30,7 @@ import
org.apache.shardingsphere.elasticjob.kernel.internal.sharding.ExecutionCo
import
org.apache.shardingsphere.elasticjob.kernel.internal.sharding.ExecutionService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.sharding.ShardingService;
import org.apache.shardingsphere.elasticjob.reg.base.CoordinatorRegistryCenter;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.tracing.JobTracingEventBus;
import
org.apache.shardingsphere.elasticjob.kernel.internal.tracing.api.TracingConfiguration;
import
org.apache.shardingsphere.elasticjob.kernel.internal.tracing.event.JobExecutionEvent;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobJobRuntimeServiceImpl.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobJobRuntimeServiceImpl.java
index 47d965c37..426e9b41c 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobJobRuntimeServiceImpl.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobJobRuntimeServiceImpl.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.executor;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
/**
* Job runtime service implementation.
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/item/JobItemExecutorFactory.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/item/JobItemExecutorFactory.java
index 9f362441f..3b6fd04c5 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/item/JobItemExecutorFactory.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/item/JobItemExecutorFactory.java
@@ -20,8 +20,8 @@ package
org.apache.shardingsphere.elasticjob.kernel.internal.executor.item;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.JobItemExecutor;
-import org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.JobItemExecutor;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobConfigurationException;
import org.apache.shardingsphere.infra.spi.ShardingSphereServiceLoader;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManager.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManager.java
index a622328aa..c1aa4ef8d 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManager.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManager.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.guarantee;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.listener.AbstractListenerManager;
import org.apache.shardingsphere.elasticjob.reg.base.CoordinatorRegistryCenter;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeService.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeService.java
index 97a957e4d..660e33517 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeService.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeService.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.guarantee;
import lombok.RequiredArgsConstructor;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/listener/ListenerManager.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/listener/ListenerManager.java
index 719cf499c..879de0894 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/listener/ListenerManager.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/listener/ListenerManager.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.RescheduleListenerManager;
import
org.apache.shardingsphere.elasticjob.kernel.internal.election.ElectionListenerManager;
import
org.apache.shardingsphere.elasticjob.kernel.internal.failover.FailoverListenerManager;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/schedule/JobScheduler.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/schedule/JobScheduler.java
index b552bdf18..82b03f3a7 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/schedule/JobScheduler.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/schedule/JobScheduler.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.elasticjob.kernel.internal.executor.ElasticJobE
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobSystemException;
import org.apache.shardingsphere.elasticjob.kernel.internal.executor.JobFacade;
import
org.apache.shardingsphere.elasticjob.kernel.internal.sharding.JobInstance;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.guarantee.GuaranteeService;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/setup/SetUpFacade.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/setup/SetUpFacade.java
index d1d884397..a7edc54a5 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/setup/SetUpFacade.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/setup/SetUpFacade.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.setup;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.election.LeaderService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.instance.InstanceService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.listener.ListenerManager;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextService.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextService.java
index 18075c062..02aa0fd01 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextService.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextService.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.sharding;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import
org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionService.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionService.java
index 1cb8799dc..9d1d4eab7 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionService.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionService.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.elasticjob.kernel.internal.sharding;
import com.google.common.base.Strings;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import
org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
diff --git
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/listener/AbstractDistributeOnceElasticJobListener.java
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/listener/AbstractDistributeOnceElasticJobListener.java
index 1e3730284..d07d01a5c 100644
---
a/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/listener/AbstractDistributeOnceElasticJobListener.java
+++
b/kernel/src/main/java/org/apache/shardingsphere/elasticjob/kernel/listener/AbstractDistributeOnceElasticJobListener.java
@@ -21,8 +21,8 @@ import lombok.Setter;
import org.apache.shardingsphere.elasticjob.kernel.internal.util.BlockUtils;
import org.apache.shardingsphere.elasticjob.kernel.internal.time.TimeService;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobSystemException;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.internal.guarantee.GuaranteeService;
import java.util.Set;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java
index 5763e0a09..c85acd44d 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/DistributeOnceElasticJobListenerTest.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.elasticjob.kernel.api.listener;
import com.google.common.collect.Sets;
import org.apache.shardingsphere.elasticjob.kernel.internal.time.TimeService;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobSystemException;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.api.listener.fixture.ElasticJobListenerCaller;
import
org.apache.shardingsphere.elasticjob.kernel.api.listener.fixture.TestDistributeOnceElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.guarantee.GuaranteeService;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestDistributeOnceElasticJobListener.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestDistributeOnceElasticJobListener.java
index cc85f1d8d..e23e83801 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestDistributeOnceElasticJobListener.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestDistributeOnceElasticJobListener.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.kernel.api.listener.fixture;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
public final class TestDistributeOnceElasticJobListener extends
AbstractDistributeOnceElasticJobListener {
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestElasticJobListener.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestElasticJobListener.java
index 07a07b03e..7db6489cd 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestElasticJobListener.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/api/listener/fixture/TestElasticJobListener.java
@@ -18,8 +18,8 @@
package org.apache.shardingsphere.elasticjob.kernel.api.listener.fixture;
import lombok.RequiredArgsConstructor;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
@RequiredArgsConstructor
public final class TestElasticJobListener implements ElasticJobListener {
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/ClassedFooJobExecutor.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/ClassedFooJobExecutor.java
index 507d0e1f2..fbe294734 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/ClassedFooJobExecutor.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/ClassedFooJobExecutor.java
@@ -18,9 +18,9 @@
package org.apache.shardingsphere.elasticjob.kernel.fixture.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor;
import org.apache.shardingsphere.elasticjob.kernel.fixture.job.FooJob;
public final class ClassedFooJobExecutor implements
ClassedJobItemExecutor<FooJob> {
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/TypedFooJobExecutor.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/TypedFooJobExecutor.java
index 50a69c9fe..52fbcd893 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/TypedFooJobExecutor.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/executor/TypedFooJobExecutor.java
@@ -19,9 +19,9 @@ package
org.apache.shardingsphere.elasticjob.kernel.fixture.executor;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor;
public final class TypedFooJobExecutor implements TypedJobItemExecutor {
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/DetailedFooJob.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/DetailedFooJob.java
index c21446e3b..2a9467319 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/DetailedFooJob.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/DetailedFooJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.fixture.job;
import lombok.Getter;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import java.util.Collection;
import java.util.concurrent.CopyOnWriteArraySet;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/FooJob.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/FooJob.java
index e2d02c3c5..f11491294 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/FooJob.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/fixture/job/FooJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.fixture.job;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
public interface FooJob extends ElasticJob {
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutorTest.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutorTest.java
index 00ad0cc88..4959da469 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutorTest.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/ElasticJobExecutorTest.java
@@ -20,10 +20,10 @@ package
org.apache.shardingsphere.elasticjob.kernel.internal.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobExecutionEnvironmentException;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobSystemException;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.fixture.executor.ClassedFooJobExecutor;
import org.apache.shardingsphere.elasticjob.kernel.fixture.job.FooJob;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
import org.apache.shardingsphere.elasticjob.test.util.ReflectionUtils;
import
org.apache.shardingsphere.elasticjob.kernel.internal.tracing.event.JobStatusTraceEvent.State;
import org.junit.jupiter.api.BeforeEach;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacadeTest.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacadeTest.java
index 857df35c5..81b6816e6 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacadeTest.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/executor/JobFacadeTest.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.elasticjob.kernel.internal.executor;
import com.google.common.collect.Lists;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
import
org.apache.shardingsphere.elasticjob.kernel.infra.exception.JobExecutionEnvironmentException;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.api.listener.fixture.ElasticJobListenerCaller;
import
org.apache.shardingsphere.elasticjob.kernel.api.listener.fixture.TestElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManagerTest.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManagerTest.java
index 9e4eb96a6..29aaca9e3 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManagerTest.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeListenerManagerTest.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.guarantee;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
import org.apache.shardingsphere.elasticjob.test.util.ReflectionUtils;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeServiceTest.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeServiceTest.java
index f2289a5e7..78787d7de 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeServiceTest.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/guarantee/GuaranteeServiceTest.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.guarantee;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextServiceTest.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextServiceTest.java
index d0571998e..8ca057eec 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextServiceTest.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionContextServiceTest.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.elasticjob.kernel.internal.sharding;
import com.google.common.collect.Lists;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import
org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
diff --git
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionServiceTest.java
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionServiceTest.java
index f7eb3d727..74cf8fdfd 100644
---
a/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionServiceTest.java
+++
b/kernel/src/test/java/org/apache/shardingsphere/elasticjob/kernel/internal/sharding/ExecutionServiceTest.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.kernel.internal.sharding;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.internal.config.ConfigurationService;
import
org.apache.shardingsphere.elasticjob.kernel.internal.schedule.JobRegistry;
import
org.apache.shardingsphere.elasticjob.kernel.internal.storage.JobNodeStorage;
diff --git
a/kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
b/kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
similarity index 100%
rename from
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
rename to
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
diff --git
a/kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
b/kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
similarity index 100%
rename from
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
rename to
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
diff --git
a/kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
b/kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
similarity index 100%
rename from
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
rename to
kernel/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
diff --git
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/CustomClassedJobExecutor.java
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/CustomClassedJobExecutor.java
index 8a7032dae..c3ea0c544 100644
---
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/CustomClassedJobExecutor.java
+++
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/CustomClassedJobExecutor.java
@@ -18,9 +18,9 @@
package org.apache.shardingsphere.elasticjob.spring.boot.job.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor;
import
org.apache.shardingsphere.elasticjob.spring.boot.job.fixture.job.CustomJob;
public final class CustomClassedJobExecutor implements
ClassedJobItemExecutor<CustomJob> {
diff --git
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/PrintJobExecutor.java
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/PrintJobExecutor.java
index 35a0c3fe8..43f7d249c 100644
---
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/PrintJobExecutor.java
+++
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/executor/PrintJobExecutor.java
@@ -20,9 +20,9 @@ package
org.apache.shardingsphere.elasticjob.spring.boot.job.executor;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor;
@Slf4j
public final class PrintJobExecutor implements TypedJobItemExecutor {
diff --git
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/CustomJob.java
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/CustomJob.java
index d204129f1..b3015cca8 100644
---
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/CustomJob.java
+++
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/CustomJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.spring.boot.job.fixture.job;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
public interface CustomJob extends ElasticJob {
diff --git
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/AnnotationCustomJob.java
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/AnnotationCustomJob.java
index 1b5ac1ef4..7992abc35 100644
---
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/AnnotationCustomJob.java
+++
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/AnnotationCustomJob.java
@@ -21,7 +21,7 @@ import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobConfiguration;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobProp;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import
org.apache.shardingsphere.elasticjob.spring.boot.job.fixture.job.CustomJob;
import org.springframework.transaction.annotation.Transactional;
diff --git
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/CustomTestJob.java
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/CustomTestJob.java
index abc871227..ebda24390 100644
---
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/CustomTestJob.java
+++
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/job/impl/CustomTestJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.spring.boot.job.fixture.job.impl;
import lombok.extern.slf4j.Slf4j;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import
org.apache.shardingsphere.elasticjob.spring.boot.job.fixture.job.CustomJob;
import
org.apache.shardingsphere.elasticjob.spring.boot.job.repository.BarRepository;
import org.springframework.beans.factory.annotation.Autowired;
diff --git
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/LogElasticJobListener.java
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/LogElasticJobListener.java
index 13c318edb..efe98402b 100644
---
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/LogElasticJobListener.java
+++
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/LogElasticJobListener.java
@@ -18,8 +18,8 @@
package org.apache.shardingsphere.elasticjob.spring.boot.job.fixture.listener;
import lombok.extern.slf4j.Slf4j;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
/**
* Log elastic job listener.
diff --git
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/NoopElasticJobListener.java
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/NoopElasticJobListener.java
index 665f92614..71701b371 100644
---
a/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/NoopElasticJobListener.java
+++
b/spring/boot-starter/src/test/java/org/apache/shardingsphere/elasticjob/spring/boot/job/fixture/listener/NoopElasticJobListener.java
@@ -17,8 +17,8 @@
package org.apache.shardingsphere.elasticjob.spring.boot.job.fixture.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
/**
* No operation elastic job listener.
diff --git
a/spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
b/spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
similarity index 100%
rename from
spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
rename to
spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
diff --git
a/spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
b/spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
similarity index 100%
rename from
spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.TypedJobItemExecutor
rename to
spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.TypedJobItemExecutor
diff --git
a/spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
b/spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
similarity index 100%
rename from
spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
rename to
spring/boot-starter/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
diff --git
a/spring/core/src/test/java/org/apache/shardingsphere/elasticjob/spring/core/util/TargetJob.java
b/spring/core/src/test/java/org/apache/shardingsphere/elasticjob/spring/core/util/TargetJob.java
index 32c8b0ab6..1b100c73b 100644
---
a/spring/core/src/test/java/org/apache/shardingsphere/elasticjob/spring/core/util/TargetJob.java
+++
b/spring/core/src/test/java/org/apache/shardingsphere/elasticjob/spring/core/util/TargetJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.spring.core.util;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
public class TargetJob implements ElasticJob {
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/DataflowElasticJob.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/DataflowElasticJob.java
index 13fdb6fdd..dd2345f31 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/DataflowElasticJob.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/DataflowElasticJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.spring.namespace.fixture.job;
import lombok.Getter;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.dataflow.job.DataflowJob;
import java.util.Collections;
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/FooSimpleElasticJob.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/FooSimpleElasticJob.java
index dd96a6920..a2adbe133 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/FooSimpleElasticJob.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/FooSimpleElasticJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.spring.namespace.fixture.job;
import lombok.Getter;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
public class FooSimpleElasticJob implements SimpleJob {
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/annotation/AnnotationSimpleJob.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/annotation/AnnotationSimpleJob.java
index fbcc8e000..eb17cc274 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/annotation/AnnotationSimpleJob.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/annotation/AnnotationSimpleJob.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.elasticjob.spring.namespace.fixture.job.annota
import lombok.Getter;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobConfiguration;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobProp;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
@Getter
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooDataflowElasticJob.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooDataflowElasticJob.java
index 3456ba7ea..2dfa99819 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooDataflowElasticJob.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooDataflowElasticJob.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.elasticjob.spring.namespace.fixture.job.ref;
import lombok.Getter;
import lombok.Setter;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.dataflow.job.DataflowJob;
import
org.apache.shardingsphere.elasticjob.spring.namespace.fixture.service.FooService;
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooSimpleElasticJob.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooSimpleElasticJob.java
index d2f9889c2..d65ddf577 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooSimpleElasticJob.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/job/ref/RefFooSimpleElasticJob.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.elasticjob.spring.namespace.fixture.job.ref;
import lombok.Getter;
import lombok.Setter;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
import
org.apache.shardingsphere.elasticjob.spring.namespace.fixture.service.FooService;
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleCglibListener.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleCglibListener.java
index 33ba3e5e7..c5006a924 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleCglibListener.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleCglibListener.java
@@ -17,8 +17,8 @@
package org.apache.shardingsphere.elasticjob.spring.namespace.fixture.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleJdkDynamicProxyListener.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleJdkDynamicProxyListener.java
index 93cd09451..ff098a269 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleJdkDynamicProxyListener.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleJdkDynamicProxyListener.java
@@ -17,8 +17,8 @@
package org.apache.shardingsphere.elasticjob.spring.namespace.fixture.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleListener.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleListener.java
index fc083672b..c150327d0 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleListener.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleListener.java
@@ -17,8 +17,8 @@
package org.apache.shardingsphere.elasticjob.spring.namespace.fixture.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import static org.hamcrest.CoreMatchers.is;
import static org.hamcrest.MatcherAssert.assertThat;
diff --git
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleOnceListener.java
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleOnceListener.java
index b1869d41f..4e75613eb 100644
---
a/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleOnceListener.java
+++
b/spring/namespace/src/test/java/org/apache/shardingsphere/elasticjob/spring/namespace/fixture/listener/SimpleOnceListener.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.spring.namespace.fixture.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
import
org.apache.shardingsphere.elasticjob.spring.namespace.fixture.service.FooService;
import org.springframework.beans.factory.annotation.Autowired;
diff --git
a/spring/namespace/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
b/spring/namespace/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
similarity index 100%
rename from
spring/namespace/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
rename to
spring/namespace/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
diff --git
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationSimpleJob.java
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationSimpleJob.java
index c6bade33b..babcc7c60 100644
---
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationSimpleJob.java
+++
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationSimpleJob.java
@@ -21,7 +21,7 @@ import lombok.Getter;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobConfiguration;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobProp;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
@ElasticJobConfiguration(
jobName = "AnnotationSimpleJob",
diff --git
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationUnShardingJob.java
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationUnShardingJob.java
index aa9d890d7..0bd7def12 100644
---
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationUnShardingJob.java
+++
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/annotation/fixture/AnnotationUnShardingJob.java
@@ -20,7 +20,7 @@ package
org.apache.shardingsphere.elasticjob.test.e2e.annotation.fixture;
import lombok.Getter;
import org.apache.shardingsphere.elasticjob.annotation.ElasticJobConfiguration;
import org.apache.shardingsphere.elasticjob.simple.job.SimpleJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
@ElasticJobConfiguration(jobName = "AnnotationUnShardingJob", description =
"desc", shardingTotalCount = 1)
@Getter
diff --git
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/executor/E2EFixtureJobExecutor.java
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/executor/E2EFixtureJobExecutor.java
index 5b6319a4e..ef5732995 100644
---
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/executor/E2EFixtureJobExecutor.java
+++
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/executor/E2EFixtureJobExecutor.java
@@ -18,9 +18,9 @@
package org.apache.shardingsphere.elasticjob.test.e2e.raw.fixture.executor;
import org.apache.shardingsphere.elasticjob.api.JobConfiguration;
-import org.apache.shardingsphere.elasticjob.spi.param.JobRuntimeService;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
-import org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor;
+import
org.apache.shardingsphere.elasticjob.spi.executor.param.JobRuntimeService;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
+import
org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor;
import
org.apache.shardingsphere.elasticjob.test.e2e.raw.fixture.job.E2EFixtureJob;
public final class E2EFixtureJobExecutor implements
ClassedJobItemExecutor<E2EFixtureJob> {
diff --git
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJob.java
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJob.java
index 7be1ba4e4..9b2aec429 100644
---
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJob.java
+++
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJob.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.test.e2e.raw.fixture.job;
import org.apache.shardingsphere.elasticjob.api.ElasticJob;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
public interface E2EFixtureJob extends ElasticJob {
diff --git
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJobImpl.java
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJobImpl.java
index d86b84b30..8bfe65c7f 100644
---
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJobImpl.java
+++
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/job/E2EFixtureJobImpl.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.elasticjob.test.e2e.raw.fixture.job;
import lombok.Getter;
-import org.apache.shardingsphere.elasticjob.spi.param.ShardingContext;
+import org.apache.shardingsphere.elasticjob.spi.executor.param.ShardingContext;
import java.util.Collection;
import java.util.concurrent.CopyOnWriteArraySet;
diff --git
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/DistributeOnceE2EFixtureJobListener.java
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/DistributeOnceE2EFixtureJobListener.java
index 0df40380b..35c46c9ee 100644
---
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/DistributeOnceE2EFixtureJobListener.java
+++
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/DistributeOnceE2EFixtureJobListener.java
@@ -17,7 +17,7 @@
package org.apache.shardingsphere.elasticjob.test.e2e.raw.fixture.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
import
org.apache.shardingsphere.elasticjob.kernel.listener.AbstractDistributeOnceElasticJobListener;
public class DistributeOnceE2EFixtureJobListener extends
AbstractDistributeOnceElasticJobListener {
diff --git
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/E2EFixtureJobListener.java
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/E2EFixtureJobListener.java
index 0ded3ad09..832067cd0 100644
---
a/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/E2EFixtureJobListener.java
+++
b/test/e2e/src/test/java/org/apache/shardingsphere/elasticjob/test/e2e/raw/fixture/listener/E2EFixtureJobListener.java
@@ -17,8 +17,8 @@
package org.apache.shardingsphere.elasticjob.test.e2e.raw.fixture.listener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener;
-import
org.apache.shardingsphere.elasticjob.kernel.infra.listener.ShardingContexts;
+import org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener;
+import
org.apache.shardingsphere.elasticjob.spi.listener.param.ShardingContexts;
public class E2EFixtureJobListener implements ElasticJobListener {
diff --git
a/test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
b/test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
similarity index 100%
rename from
test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.type.ClassedJobItemExecutor
rename to
test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.executor.type.ClassedJobItemExecutor
diff --git
a/test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
b/test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
similarity index 100%
rename from
test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.kernel.infra.listener.ElasticJobListener
rename to
test/e2e/src/test/resources/META-INF/services/org.apache.shardingsphere.elasticjob.spi.listener.ElasticJobListener
