This is an automated email from the ASF dual-hosted git repository.
zhangliang 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 056deb9 Revise code style (#1320)
056deb9 is described below
commit 056deb9ddca78301ce3e1ac1ae6d7db8bf9cb6b0
Author: Liang Zhang <[email protected]>
AuthorDate: Mon Aug 3 13:01:53 2020 +0800
Revise code style (#1320)
---
.../example/controller/OneOffJobController.java | 4 ++--
.../elasticjob/lite/example/entity/Foo.java | 22 +++++++++++-----------
.../lite/example/job/SpringBootDataflowJob.java | 8 ++++----
.../lite/example/job/SpringBootSimpleJob.java | 6 +++---
.../lite/example/repository/FooRepository.java | 12 ++++++------
5 files changed, 26 insertions(+), 26 deletions(-)
diff --git
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/controller/OneOffJobController.java
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/controller/OneOffJobController.java
index 075e750..4031893 100644
---
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/controller/OneOffJobController.java
+++
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/controller/OneOffJobController.java
@@ -27,10 +27,10 @@ import javax.annotation.Resource;
@RestController
@DependsOn("org.apache.shardingsphere.elasticjob.lite.spring.boot.job.ElasticJobLiteAutoConfiguration")
public class OneOffJobController {
-
+
@Resource(name = "manualScriptJobOneOffJobBootstrap")
private OneOffJobBootstrap manualScriptJob;
-
+
@GetMapping("/execute")
public String executeOneOffJob() {
manualScriptJob.execute();
diff --git
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/entity/Foo.java
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/entity/Foo.java
index 59243a8..e999960 100644
---
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/entity/Foo.java
+++
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/entity/Foo.java
@@ -20,42 +20,42 @@ package
org.apache.shardingsphere.elasticjob.lite.example.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;
}
-
+
@Override
public String toString() {
return String.format("id: %s, location: %s, status: %s", id, location,
status);
}
-
+
public enum Status {
TODO,
COMPLETED
diff --git
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootDataflowJob.java
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootDataflowJob.java
index c7f5b61..337777e 100644
---
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootDataflowJob.java
+++
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootDataflowJob.java
@@ -32,19 +32,19 @@ import java.util.List;
@Component
public class SpringBootDataflowJob implements DataflowJob<Foo> {
-
+
private final Logger logger =
LoggerFactory.getLogger(SpringBootDataflowJob.class);
-
+
@Resource
private FooRepository fooRepository;
-
+
@Override
public List<Foo> fetchData(final ShardingContext shardingContext) {
logger.info("Item: {} | Time: {} | Thread: {} | {}",
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) {
logger.info("Item: {} | Time: {} | Thread: {} | {}",
diff --git
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootSimpleJob.java
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootSimpleJob.java
index ac6cdb1..416202a 100644
---
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootSimpleJob.java
+++
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/job/SpringBootSimpleJob.java
@@ -32,12 +32,12 @@ import java.util.List;
@Component
public class SpringBootSimpleJob implements SimpleJob {
-
+
private final Logger logger =
LoggerFactory.getLogger(SpringBootSimpleJob.class);
-
+
@Autowired
private FooRepository fooRepository;
-
+
@Override
public void execute(ShardingContext shardingContext) {
logger.info("Item: {} | Time: {} | Thread: {} | {}",
diff --git
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/repository/FooRepository.java
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/repository/FooRepository.java
index b68a04a..507db9d 100644
---
a/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/repository/FooRepository.java
+++
b/examples/elasticjob-example-lite-springboot/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/repository/FooRepository.java
@@ -27,25 +27,25 @@ import java.util.concurrent.ConcurrentHashMap;
@Repository
public class FooRepository {
-
+
private final 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;
@@ -61,7 +61,7 @@ public class FooRepository {
}
return result;
}
-
+
public void setCompleted(final long id) {
data.get(id).setStatus(Foo.Status.COMPLETED);
}
