This is an automated email from the ASF dual-hosted git repository.
zhaojinchao 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 79ad4c0b062 Refactor shardingsphere-system-time-service module (#23731)
79ad4c0b062 is described below
commit 79ad4c0b062fe3c152fbf55aeef4668dc57fb1c5
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Jan 26 22:40:54 2023 +0800
Refactor shardingsphere-system-time-service module (#23731)
* Refactor CDCOrder
* Refactor shardingsphere-system-time-service module
---
.../shardingsphere/data/pipeline/cdc/constant/CDCOrder.java | 5 ++++-
.../system/SystemTimeService.java} | 6 +++---
...pache.shardingsphere.timeservice.spi.ShardingSphereTimeService | 2 +-
.../system/SystemTimeServiceTest.java} | 8 ++++----
4 files changed, 12 insertions(+), 9 deletions(-)
diff --git
a/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/constant/CDCOrder.java
b/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/constant/CDCOrder.java
index 7fc35073699..7ea9fccaf21 100644
---
a/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/constant/CDCOrder.java
+++
b/kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/constant/CDCOrder.java
@@ -18,9 +18,12 @@
package org.apache.shardingsphere.data.pipeline.cdc.constant;
/**
- * CDC rule order of load.
+ * CDC rule order.
*/
public final class CDCOrder {
+ /**
+ * CDC order.
+ */
public static final int ORDER = 10000;
}
diff --git
a/kernel/time-service/type/system/src/main/java/org/apache/shardingsphere/timeservice/system/SystemDatetimeService.java
b/kernel/time-service/type/system/src/main/java/org/apache/shardingsphere/timeservice/type/system/SystemTimeService.java
similarity index 87%
rename from
kernel/time-service/type/system/src/main/java/org/apache/shardingsphere/timeservice/system/SystemDatetimeService.java
rename to
kernel/time-service/type/system/src/main/java/org/apache/shardingsphere/timeservice/type/system/SystemTimeService.java
index 54970f02a5b..d67c17a346e 100644
---
a/kernel/time-service/type/system/src/main/java/org/apache/shardingsphere/timeservice/system/SystemDatetimeService.java
+++
b/kernel/time-service/type/system/src/main/java/org/apache/shardingsphere/timeservice/type/system/SystemTimeService.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.timeservice.system;
+package org.apache.shardingsphere.timeservice.type.system;
import org.apache.shardingsphere.timeservice.spi.ShardingSphereTimeService;
import java.util.Date;
/**
- * System datetime service.
+ * System time service.
*/
-public final class SystemDatetimeService implements ShardingSphereTimeService {
+public final class SystemTimeService implements ShardingSphereTimeService {
@Override
public Date getDatetime() {
diff --git
a/kernel/time-service/type/system/src/main/resources/META-INF/services/org.apache.shardingsphere.timeservice.spi.ShardingSphereTimeService
b/kernel/time-service/type/system/src/main/resources/META-INF/services/org.apache.shardingsphere.timeservice.spi.ShardingSphereTimeService
index 9ff56e112a7..e27971a4272 100644
---
a/kernel/time-service/type/system/src/main/resources/META-INF/services/org.apache.shardingsphere.timeservice.spi.ShardingSphereTimeService
+++
b/kernel/time-service/type/system/src/main/resources/META-INF/services/org.apache.shardingsphere.timeservice.spi.ShardingSphereTimeService
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.timeservice.system.SystemDatetimeService
+org.apache.shardingsphere.timeservice.type.system.SystemTimeService
diff --git
a/kernel/time-service/type/system/src/test/java/org/apache/shardingsphere/timeservice/system/SystemDatetimeServiceTest.java
b/kernel/time-service/type/system/src/test/java/org/apache/shardingsphere/timeservice/type/system/SystemTimeServiceTest.java
similarity index 78%
rename from
kernel/time-service/type/system/src/test/java/org/apache/shardingsphere/timeservice/system/SystemDatetimeServiceTest.java
rename to
kernel/time-service/type/system/src/test/java/org/apache/shardingsphere/timeservice/type/system/SystemTimeServiceTest.java
index acc0f86a148..8766d3cf335 100644
---
a/kernel/time-service/type/system/src/test/java/org/apache/shardingsphere/timeservice/system/SystemDatetimeServiceTest.java
+++
b/kernel/time-service/type/system/src/test/java/org/apache/shardingsphere/timeservice/type/system/SystemTimeServiceTest.java
@@ -15,21 +15,21 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.timeservice.system;
+package org.apache.shardingsphere.timeservice.type.system;
import org.junit.Test;
import static org.junit.Assert.assertTrue;
-public final class SystemDatetimeServiceTest {
+public final class SystemTimeServiceTest {
@Test
public void assertGetDatetime() {
- assertTrue(new SystemDatetimeService().getDatetime().getTime() <=
System.currentTimeMillis());
+ assertTrue(new SystemTimeService().getDatetime().getTime() <=
System.currentTimeMillis());
}
@Test
public void assertIsDefault() {
- assertTrue(new SystemDatetimeService().isDefault());
+ assertTrue(new SystemTimeService().isDefault());
}
}