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 0e9df361f6c Fix javadoc on ComputeNodePersistService (#34249)
0e9df361f6c is described below
commit 0e9df361f6c9d735554bd3280d4fc710efd5ea7b
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Jan 4 23:34:22 2025 +0800
Fix javadoc on ComputeNodePersistService (#34249)
---
.../service/unified/ComputeNodePersistService.java | 28 +++++++++++-----------
1 file changed, 14 insertions(+), 14 deletions(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/persist/service/unified/ComputeNodePersistService.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/persist/service/unified/ComputeNodePersistService.java
index e58dd08113a..9c37b094ad2 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/persist/service/unified/ComputeNodePersistService.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/persist/service/unified/ComputeNodePersistService.java
@@ -65,7 +65,7 @@ public final class ComputeNodePersistService {
/**
* Persist instance labels.
*
- * @param instanceId instance id
+ * @param instanceId instance ID
* @param labels instance labels
*/
public void persistInstanceLabels(final String instanceId, final
Collection<String> labels) {
@@ -73,10 +73,10 @@ public final class ComputeNodePersistService {
}
/**
- * Persist instance worker id.
+ * Persist instance worker ID.
*
- * @param instanceId instance id
- * @param workerId worker id
+ * @param instanceId instance ID
+ * @param workerId worker ID
*/
public void persistInstanceWorkerId(final String instanceId, final int
workerId) {
repository.persistEphemeral(ComputeNode.getInstanceWorkerIdNodePath(instanceId),
String.valueOf(workerId));
@@ -85,7 +85,7 @@ public final class ComputeNodePersistService {
/**
* Load instance labels.
*
- * @param instanceId instance id
+ * @param instanceId instance ID
* @return labels
*/
@SuppressWarnings("unchecked")
@@ -97,7 +97,7 @@ public final class ComputeNodePersistService {
/**
* Load compute node state.
*
- * @param instanceId instance id
+ * @param instanceId instance ID
* @return state
*/
public String loadComputeNodeState(final String instanceId) {
@@ -105,10 +105,10 @@ public final class ComputeNodePersistService {
}
/**
- * Load instance worker id.
+ * Load instance worker ID.
*
- * @param instanceId instance id
- * @return worker id
+ * @param instanceId instance ID
+ * @return worker ID
*/
public Optional<Integer> loadInstanceWorkerId(final String instanceId) {
try {
@@ -143,9 +143,9 @@ public final class ComputeNodePersistService {
}
/**
- * Load compute node instance by instance definition.
+ * Load compute node instance by instance meta data.
*
- * @param instanceMetaData instance definition
+ * @param instanceMetaData instance meta data
* @return compute node instance
*/
public ComputeNodeInstance loadComputeNodeInstance(final InstanceMetaData
instanceMetaData) {
@@ -157,9 +157,9 @@ public final class ComputeNodePersistService {
}
/**
- * Get assigned worker ids.
+ * Get assigned worker IDs.
*
- * @return assigned worker ids
+ * @return assigned worker IDs
*/
public Collection<Integer> getAssignedWorkerIds() {
Collection<String> childrenKeys =
repository.getChildrenKeys(ComputeNode.getInstanceWorkerIdRootNodePath());
@@ -176,7 +176,7 @@ public final class ComputeNodePersistService {
/**
* Update compute node state.
*
- * @param instanceId instance id
+ * @param instanceId instance ID
* @param instanceState instance state
*/
public void updateComputeNodeState(final String instanceId, final
InstanceState instanceState) {
