Refactor package names.
diff --git a/elastic-job-example-cloud/src/main/java/com/dangdang/ddframe/job/example/CloudJobMain.java b/elastic-job-example-cloud/src/main/java/com/dangdang/ddframe/job/example/CloudJobMain.java
deleted file mode 100644
index 5967372..0000000
--- a/elastic-job-example-cloud/src/main/java/com/dangdang/ddframe/job/example/CloudJobMain.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example;
-
-import com.dangdang.ddframe.job.cloud.api.JobBootstrap;
-
-public final class CloudJobMain {
-
- // CHECKSTYLE:OFF
- public static void main(final String[] args) {
- // CHECKSTYLE:ON
- JobBootstrap.execute();
- }
-}
diff --git a/elastic-job-example-cloud/src/main/java/io/elasticjob/cloud/CloudJobMain.java b/elastic-job-example-cloud/src/main/java/io/elasticjob/cloud/example/CloudJobMain.java
similarity index 95%
rename from elastic-job-example-cloud/src/main/java/io/elasticjob/cloud/CloudJobMain.java
rename to elastic-job-example-cloud/src/main/java/io/elasticjob/cloud/example/CloudJobMain.java
index a06e897..26f3d74 100644
--- a/elastic-job-example-cloud/src/main/java/io/elasticjob/cloud/CloudJobMain.java
+++ b/elastic-job-example-cloud/src/main/java/io/elasticjob/cloud/example/CloudJobMain.java
@@ -15,7 +15,7 @@
* </p>
*/
-package io.elasticjob.cloud;
+package io.elasticjob.cloud.example;
import io.elasticjob.cloud.api.JobBootstrap;
diff --git a/elastic-job-example-jobs/pom.xml b/elastic-job-example-jobs/pom.xml
index 0691419..0230b6b 100644
--- a/elastic-job-example-jobs/pom.xml
+++ b/elastic-job-example-jobs/pom.xml
@@ -11,7 +11,7 @@
<dependencies>
<dependency>
<groupId>io.elasticjob</groupId>
- <artifactId>elastic-job-common-core</artifactId>
+ <artifactId>elastic-job-lite-core</artifactId>
<version>${project.parent.version}</version>
</dependency>
<dependency>
diff --git a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/entity/Foo.java b/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/entity/Foo.java
deleted file mode 100644
index 4acdfb6..0000000
--- a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/entity/Foo.java
+++ /dev/null
@@ -1,62 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example.fixture.entity;
-
-import java.io.Serializable;
-
-public final class Foo implements Serializable {
-
- private static final long serialVersionUID = 2706842871078949451L;
-
- private final long id;
-
- private final String location;
-
- private Status status;
-
- public Foo(final long id, final String location, final Status status) {
- this.id = id;
- this.location = location;
- this.status = status;
- }
-
- public long getId() {
- return id;
- }
-
- public String getLocation() {
- return location;
- }
-
- public Status getStatus() {
- return status;
- }
-
- public void setStatus(final Status status) {
- this.status = status;
- }
-
- public String toString() {
- return String.format("id: %s, location: %s, status: %s", id, location, status);
- }
-
- public enum Status {
- TODO,
- COMPLETED
- }
-}
diff --git a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/repository/FooRepository.java b/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/repository/FooRepository.java
deleted file mode 100644
index 2ce4577..0000000
--- a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/repository/FooRepository.java
+++ /dev/null
@@ -1,68 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example.fixture.repository;
-
-import com.dangdang.ddframe.job.example.fixture.entity.Foo;
-import org.springframework.stereotype.Repository;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-
-@Repository
-public class FooRepository {
-
- private Map<Long, Foo> data = new ConcurrentHashMap<>(300, 1);
-
- public FooRepository() {
- init();
- }
-
- private void init() {
- addData(0L, 100L, "Beijing");
- addData(100L, 200L, "Shanghai");
- addData(200L, 300L, "Guangzhou");
- }
-
- private void addData(final long idFrom, final long idTo, final String location) {
- for (long i = idFrom; i < idTo; i++) {
- data.put(i, new Foo(i, location, Foo.Status.TODO));
- }
- }
-
- public List<Foo> findTodoData(final String location, final int limit) {
- List<Foo> result = new ArrayList<>(limit);
- int count = 0;
- for (Map.Entry<Long, Foo> each : data.entrySet()) {
- Foo foo = each.getValue();
- if (foo.getLocation().equals(location) && foo.getStatus() == Foo.Status.TODO) {
- result.add(foo);
- count++;
- if (count == limit) {
- break;
- }
- }
- }
- return result;
- }
-
- public void setCompleted(final long id) {
- data.get(id).setStatus(Foo.Status.COMPLETED);
- }
-}
diff --git a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/repository/FooRepositoryFactory.java b/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/repository/FooRepositoryFactory.java
deleted file mode 100644
index fd47341..0000000
--- a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/fixture/repository/FooRepositoryFactory.java
+++ /dev/null
@@ -1,28 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example.fixture.repository;
-
-public final class FooRepositoryFactory {
-
- private static FooRepository fooRepository = new FooRepository();
-
- public static FooRepository getFooRepository() {
- return fooRepository;
- }
-
-}
diff --git a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/dataflow/JavaDataflowJob.java b/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/dataflow/JavaDataflowJob.java
deleted file mode 100644
index 9c49240..0000000
--- a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/dataflow/JavaDataflowJob.java
+++ /dev/null
@@ -1,49 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example.job.dataflow;
-
-import com.dangdang.ddframe.job.api.ShardingContext;
-import com.dangdang.ddframe.job.api.dataflow.DataflowJob;
-import com.dangdang.ddframe.job.example.fixture.entity.Foo;
-import com.dangdang.ddframe.job.example.fixture.repository.FooRepository;
-import com.dangdang.ddframe.job.example.fixture.repository.FooRepositoryFactory;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.List;
-
-public class JavaDataflowJob implements DataflowJob<Foo> {
-
- private FooRepository fooRepository = FooRepositoryFactory.getFooRepository();
-
- @Override
- public List<Foo> fetchData(final ShardingContext shardingContext) {
- System.out.println(String.format("Item: %s | Time: %s | Thread: %s | %s",
- shardingContext.getShardingItem(), new SimpleDateFormat("HH:mm:ss").format(new Date()), Thread.currentThread().getId(), "DATAFLOW FETCH"));
- return fooRepository.findTodoData(shardingContext.getShardingParameter(), 10);
- }
-
- @Override
- public void processData(final ShardingContext shardingContext, final List<Foo> data) {
- System.out.println(String.format("Item: %s | Time: %s | Thread: %s | %s",
- shardingContext.getShardingItem(), new SimpleDateFormat("HH:mm:ss").format(new Date()), Thread.currentThread().getId(), "DATAFLOW PROCESS"));
- for (Foo each : data) {
- fooRepository.setCompleted(each.getId());
- }
- }
-}
diff --git a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/dataflow/SpringDataflowJob.java b/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/dataflow/SpringDataflowJob.java
deleted file mode 100644
index 02f4590..0000000
--- a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/dataflow/SpringDataflowJob.java
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example.job.dataflow;
-
-import com.dangdang.ddframe.job.api.ShardingContext;
-import com.dangdang.ddframe.job.api.dataflow.DataflowJob;
-import com.dangdang.ddframe.job.example.fixture.entity.Foo;
-import com.dangdang.ddframe.job.example.fixture.repository.FooRepository;
-
-import javax.annotation.Resource;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.List;
-
-public class SpringDataflowJob implements DataflowJob<Foo> {
-
- @Resource
- private FooRepository fooRepository;
-
- @Override
- public List<Foo> fetchData(final ShardingContext shardingContext) {
- System.out.println(String.format("Item: %s | Time: %s | Thread: %s | %s",
- shardingContext.getShardingItem(), new SimpleDateFormat("HH:mm:ss").format(new Date()), Thread.currentThread().getId(), "DATAFLOW FETCH"));
- return fooRepository.findTodoData(shardingContext.getShardingParameter(), 10);
- }
-
- @Override
- public void processData(final ShardingContext shardingContext, final List<Foo> data) {
- System.out.println(String.format("Item: %s | Time: %s | Thread: %s | %s",
- shardingContext.getShardingItem(), new SimpleDateFormat("HH:mm:ss").format(new Date()), Thread.currentThread().getId(), "DATAFLOW PROCESS"));
- for (Foo each : data) {
- fooRepository.setCompleted(each.getId());
- }
- }
-}
diff --git a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/simple/JavaSimpleJob.java b/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/simple/JavaSimpleJob.java
deleted file mode 100644
index 511ac11..0000000
--- a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/simple/JavaSimpleJob.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example.job.simple;
-
-import com.dangdang.ddframe.job.api.ShardingContext;
-import com.dangdang.ddframe.job.api.simple.SimpleJob;
-import com.dangdang.ddframe.job.example.fixture.entity.Foo;
-import com.dangdang.ddframe.job.example.fixture.repository.FooRepository;
-import com.dangdang.ddframe.job.example.fixture.repository.FooRepositoryFactory;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.List;
-
-public class JavaSimpleJob implements SimpleJob {
-
- private FooRepository fooRepository = FooRepositoryFactory.getFooRepository();
-
- @Override
- public void execute(final ShardingContext shardingContext) {
- System.out.println(String.format("Item: %s | Time: %s | Thread: %s | %s",
- shardingContext.getShardingItem(), new SimpleDateFormat("HH:mm:ss").format(new Date()), Thread.currentThread().getId(), "SIMPLE"));
- List<Foo> data = fooRepository.findTodoData(shardingContext.getShardingParameter(), 10);
- for (Foo each : data) {
- fooRepository.setCompleted(each.getId());
- }
- }
-}
diff --git a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/simple/SpringSimpleJob.java b/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/simple/SpringSimpleJob.java
deleted file mode 100644
index eadd649..0000000
--- a/elastic-job-example-jobs/src/main/java/com/dangdang/ddframe/job/example/job/simple/SpringSimpleJob.java
+++ /dev/null
@@ -1,44 +0,0 @@
-/*
- * Copyright 1999-2015 dangdang.com.
- * <p>
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * </p>
- */
-
-package com.dangdang.ddframe.job.example.job.simple;
-
-import com.dangdang.ddframe.job.api.ShardingContext;
-import com.dangdang.ddframe.job.api.simple.SimpleJob;
-import com.dangdang.ddframe.job.example.fixture.entity.Foo;
-import com.dangdang.ddframe.job.example.fixture.repository.FooRepository;
-
-import javax.annotation.Resource;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.List;
-
-public class SpringSimpleJob implements SimpleJob {
-
- @Resource
- private FooRepository fooRepository;
-
- @Override
- public void execute(final ShardingContext shardingContext) {
- System.out.println(String.format("Item: %s | Time: %s | Thread: %s | %s",
- shardingContext.getShardingItem(), new SimpleDateFormat("HH:mm:ss").format(new Date()), Thread.currentThread().getId(), "SIMPLE"));
- List<Foo> data = fooRepository.findTodoData(shardingContext.getShardingParameter(), 10);
- for (Foo each : data) {
- fooRepository.setCompleted(each.getId());
- }
- }
-}
diff --git a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/JavaDataflowJob.java b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/JavaDataflowJob.java
index 68c1a59..1e93339 100644
--- a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/JavaDataflowJob.java
+++ b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/JavaDataflowJob.java
@@ -17,8 +17,8 @@
package io.elasticjob.example.job.dataflow;
-import io.elasticjob.api.ShardingContext;
-import io.elasticjob.api.dataflow.DataflowJob;
+import io.elasticjob.lite.api.ShardingContext;
+import io.elasticjob.lite.api.dataflow.DataflowJob;
import io.elasticjob.example.fixture.entity.Foo;
import io.elasticjob.example.fixture.repository.FooRepository;
import io.elasticjob.example.fixture.repository.FooRepositoryFactory;
diff --git a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/SpringDataflowJob.java b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/SpringDataflowJob.java
index c66fddc..e3dfb87 100644
--- a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/SpringDataflowJob.java
+++ b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/dataflow/SpringDataflowJob.java
@@ -17,8 +17,8 @@
package io.elasticjob.example.job.dataflow;
-import io.elasticjob.api.ShardingContext;
-import io.elasticjob.api.dataflow.DataflowJob;
+import io.elasticjob.lite.api.ShardingContext;
+import io.elasticjob.lite.api.dataflow.DataflowJob;
import io.elasticjob.example.fixture.entity.Foo;
import io.elasticjob.example.fixture.repository.FooRepository;
diff --git a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/JavaSimpleJob.java b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/JavaSimpleJob.java
index f1c2117..e585e60 100644
--- a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/JavaSimpleJob.java
+++ b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/JavaSimpleJob.java
@@ -17,8 +17,8 @@
package io.elasticjob.example.job.simple;
-import io.elasticjob.api.ShardingContext;
-import io.elasticjob.api.simple.SimpleJob;
+import io.elasticjob.lite.api.ShardingContext;
+import io.elasticjob.lite.api.simple.SimpleJob;
import io.elasticjob.example.fixture.entity.Foo;
import io.elasticjob.example.fixture.repository.FooRepository;
import io.elasticjob.example.fixture.repository.FooRepositoryFactory;
diff --git a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/SpringSimpleJob.java b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/SpringSimpleJob.java
index 31f6ff8..fec6b6d 100644
--- a/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/SpringSimpleJob.java
+++ b/elastic-job-example-jobs/src/main/java/io/elasticjob/example/job/simple/SpringSimpleJob.java
@@ -17,8 +17,8 @@
package io.elasticjob.example.job.simple;
-import io.elasticjob.api.ShardingContext;
-import io.elasticjob.api.simple.SimpleJob;
+import io.elasticjob.lite.api.ShardingContext;
+import io.elasticjob.lite.api.simple.SimpleJob;
import io.elasticjob.example.fixture.entity.Foo;
import io.elasticjob.example.fixture.repository.FooRepository;
diff --git a/elastic-job-example-lite-java/src/main/java/io/elasticjob/lite/example/JavaMain.java b/elastic-job-example-lite-java/src/main/java/io/elasticjob/lite/example/JavaMain.java
index e13df3f..b6c42ed 100644
--- a/elastic-job-example-lite-java/src/main/java/io/elasticjob/lite/example/JavaMain.java
+++ b/elastic-job-example-lite-java/src/main/java/io/elasticjob/lite/example/JavaMain.java
@@ -17,19 +17,19 @@
package io.elasticjob.lite.example;
-import io.elasticjob.config.JobCoreConfiguration;
-import io.elasticjob.config.dataflow.DataflowJobConfiguration;
-import io.elasticjob.config.script.ScriptJobConfiguration;
-import io.elasticjob.config.simple.SimpleJobConfiguration;
-import io.elasticjob.event.JobEventConfiguration;
-import io.elasticjob.event.rdb.JobEventRdbConfiguration;
+import io.elasticjob.lite.config.JobCoreConfiguration;
+import io.elasticjob.lite.config.dataflow.DataflowJobConfiguration;
+import io.elasticjob.lite.config.script.ScriptJobConfiguration;
+import io.elasticjob.lite.config.simple.SimpleJobConfiguration;
+import io.elasticjob.lite.event.JobEventConfiguration;
+import io.elasticjob.lite.event.rdb.JobEventRdbConfiguration;
import io.elasticjob.example.job.dataflow.JavaDataflowJob;
import io.elasticjob.example.job.simple.JavaSimpleJob;
import io.elasticjob.lite.api.JobScheduler;
import io.elasticjob.lite.config.LiteJobConfiguration;
-import io.elasticjob.reg.base.CoordinatorRegistryCenter;
-import io.elasticjob.reg.zookeeper.ZookeeperConfiguration;
-import io.elasticjob.reg.zookeeper.ZookeeperRegistryCenter;
+import io.elasticjob.lite.reg.base.CoordinatorRegistryCenter;
+import io.elasticjob.lite.reg.zookeeper.ZookeeperConfiguration;
+import io.elasticjob.lite.reg.zookeeper.ZookeeperRegistryCenter;
import org.apache.commons.dbcp.BasicDataSource;
import javax.sql.DataSource;
diff --git a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/DataflowJobConfig.java b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/DataflowJobConfig.java
index 421920c..802e842 100644
--- a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/DataflowJobConfig.java
+++ b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/DataflowJobConfig.java
@@ -17,15 +17,15 @@
package io.elasticjob.lite.example.config;
-import io.elasticjob.api.dataflow.DataflowJob;
-import io.elasticjob.config.JobCoreConfiguration;
-import io.elasticjob.config.dataflow.DataflowJobConfiguration;
-import io.elasticjob.event.JobEventConfiguration;
+import io.elasticjob.lite.api.dataflow.DataflowJob;
+import io.elasticjob.lite.config.JobCoreConfiguration;
+import io.elasticjob.lite.config.dataflow.DataflowJobConfiguration;
+import io.elasticjob.lite.event.JobEventConfiguration;
import io.elasticjob.example.job.dataflow.SpringDataflowJob;
import io.elasticjob.lite.api.JobScheduler;
import io.elasticjob.lite.config.LiteJobConfiguration;
import io.elasticjob.lite.spring.api.SpringJobScheduler;
-import io.elasticjob.reg.zookeeper.ZookeeperRegistryCenter;
+import io.elasticjob.lite.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
diff --git a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/JobEventConfig.java b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/JobEventConfig.java
index e9de0cb..f03408c 100644
--- a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/JobEventConfig.java
+++ b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/JobEventConfig.java
@@ -17,8 +17,8 @@
package io.elasticjob.lite.example.config;
-import io.elasticjob.event.JobEventConfiguration;
-import io.elasticjob.event.rdb.JobEventRdbConfiguration;
+import io.elasticjob.lite.event.JobEventConfiguration;
+import io.elasticjob.lite.event.rdb.JobEventRdbConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
diff --git a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/RegistryCenterConfig.java b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/RegistryCenterConfig.java
index 48faefc..b62643b 100644
--- a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/RegistryCenterConfig.java
+++ b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/RegistryCenterConfig.java
@@ -17,8 +17,8 @@
package io.elasticjob.lite.example.config;
-import io.elasticjob.reg.zookeeper.ZookeeperConfiguration;
-import io.elasticjob.reg.zookeeper.ZookeeperRegistryCenter;
+import io.elasticjob.lite.reg.zookeeper.ZookeeperConfiguration;
+import io.elasticjob.lite.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
import org.springframework.context.annotation.Bean;
diff --git a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/SimpleJobConfig.java b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/SimpleJobConfig.java
index 64078dd..435b393 100644
--- a/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/SimpleJobConfig.java
+++ b/elastic-job-example-lite-springboot/src/main/java/io/elasticjob/lite/example/config/SimpleJobConfig.java
@@ -17,15 +17,15 @@
package io.elasticjob.lite.example.config;
-import io.elasticjob.api.simple.SimpleJob;
-import io.elasticjob.config.JobCoreConfiguration;
-import io.elasticjob.config.simple.SimpleJobConfiguration;
-import io.elasticjob.event.JobEventConfiguration;
+import io.elasticjob.lite.api.simple.SimpleJob;
+import io.elasticjob.lite.config.JobCoreConfiguration;
+import io.elasticjob.lite.config.simple.SimpleJobConfiguration;
+import io.elasticjob.lite.event.JobEventConfiguration;
import io.elasticjob.example.job.simple.SpringSimpleJob;
import io.elasticjob.lite.api.JobScheduler;
import io.elasticjob.lite.config.LiteJobConfiguration;
import io.elasticjob.lite.spring.api.SpringJobScheduler;
-import io.elasticjob.reg.zookeeper.ZookeeperRegistryCenter;
+import io.elasticjob.lite.reg.zookeeper.ZookeeperRegistryCenter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
diff --git a/pom.xml b/pom.xml
index 94bbfe4..d0f2056 100644
--- a/pom.xml
+++ b/pom.xml
@@ -34,7 +34,7 @@
<dependencyManagement>
<dependencies>
<dependency>
- <artifactId>elastic-job-common-core</artifactId>
+ <artifactId>elastic-job-cloud-common</artifactId>
<groupId>io.elasticjob</groupId>
<version>${elastic-job.version}</version>
</dependency>
