You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2020/07/30 02:24:30 UTC
[shardingsphere] branch master updated: format code (#6523)
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.git
The following commit(s) were added to refs/heads/master by this push:
new 9436709 format code (#6523)
9436709 is described below
commit 9436709adf8b3aabd5210a3c9d0ef1b1ca828560
Author: 邱鹿 Lucas <lu...@163.com>
AuthorDate: Thu Jul 30 10:24:09 2020 +0800
format code (#6523)
* format code.
---
.../job/position/resume/AbstractResumablePositionManager.java | 8 ++++----
.../core/job/position/resume/FakeResumablePositionManager.java | 2 +-
.../job/position/resume/ZookeeperResumablePositionManager.java | 7 ++++---
3 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/AbstractResumablePositionManager.java b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/AbstractResumablePositionManager.java
index 6e80c73..e197737 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/AbstractResumablePositionManager.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/AbstractResumablePositionManager.java
@@ -46,16 +46,16 @@ public abstract class AbstractResumablePositionManager implements ResumablePosit
private static final Gson GSON = new Gson();
+ private final Map<String, PositionManager<PrimaryKeyPosition>> inventoryPositionManagerMap = Maps.newConcurrentMap();
+
+ private final Map<String, PositionManager> incrementalPositionManagerMap = Maps.newConcurrentMap();
+
private boolean resumable;
private String databaseType;
private String taskPath;
- private final Map<String, PositionManager<PrimaryKeyPosition>> inventoryPositionManagerMap = Maps.newConcurrentMap();
-
- private final Map<String, PositionManager> incrementalPositionManagerMap = Maps.newConcurrentMap();
-
@Override
public void persistInventoryPosition() {
}
diff --git a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/FakeResumablePositionManager.java b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/FakeResumablePositionManager.java
index 2993b40..f01bef6 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/FakeResumablePositionManager.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/FakeResumablePositionManager.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.scaling.core.job.position.resume;
/**
- * Fake resumable position manager as defalut.
+ * Fake resumable position manager as default.
*/
public final class FakeResumablePositionManager extends AbstractResumablePositionManager implements ResumablePositionManager {
diff --git a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/ZookeeperResumablePositionManager.java b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/ZookeeperResumablePositionManager.java
index 2dca59d..808b520 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/ZookeeperResumablePositionManager.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/resume/ZookeeperResumablePositionManager.java
@@ -42,11 +42,11 @@ public final class ZookeeperResumablePositionManager extends AbstractResumablePo
private static boolean available;
- private ScheduledExecutorService executor;
+ private final ScheduledExecutorService executor;
- private String inventoryPath;
+ private final String inventoryPath;
- private String incrementalPath;
+ private final String incrementalPath;
static {
ResumeConfiguration resumeConfiguration = ScalingContext.getInstance().getServerConfiguration().getResumeConfiguration();
@@ -70,6 +70,7 @@ public final class ZookeeperResumablePositionManager extends AbstractResumablePo
/**
* If it is available.
+ *
* @return is available
*/
public static boolean isAvailable() {