This is an automated email from the ASF dual-hosted git repository.
yangjiaqi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
The following commit(s) were added to refs/heads/master by this push:
new 2e27c583b chore(pd): translate CJK punctuations to English (#2625)
2e27c583b is described below
commit 2e27c583b4a377492a80d4ad71901d925559b7a4
Author: V_Galaxy <[email protected]>
AuthorDate: Sat Aug 10 12:16:51 2024 +0800
chore(pd): translate CJK punctuations to English (#2625)
---
.../org/apache/hugegraph/pd/client/PDClient.java | 16 ++++++++--------
.../org/apache/hugegraph/pd/PartitionService.java | 22 +++++++++++-----------
.../org/apache/hugegraph/pd/StoreNodeService.java | 2 +-
3 files changed, 20 insertions(+), 20 deletions(-)
diff --git
a/hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDClient.java
b/hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDClient.java
index 17318595f..200a35ee8 100644
---
a/hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDClient.java
+++
b/hugegraph-pd/hg-pd-client/src/main/java/org/apache/hugegraph/pd/client/PDClient.java
@@ -1019,7 +1019,7 @@ public class PDClient {
/**
* Working mode
- * Auto:If the number of partitions on each store reaches the maximum
value, you need to
+ * Auto: If the number of partitions on each store reaches the maximum
value, you need to
* specify the store group id. The store group id is 0, which is the
default partition
* splitData(ClusterOp.OperationMode mode, int storeGroupId,
List<ClusterOp.SplitDataParam>
* params)
@@ -1038,9 +1038,9 @@ public class PDClient {
/**
* Working mode
- * Auto:If the number of partitions on each store reaches the maximum
value, you need to
+ * Auto: If the number of partitions on each store reaches the maximum
value, you need to
* specify the store group id. The store group id is 0, which is the
default partition
- * Expert:Expert Mode,Specifier is required splitParams, limit
SplitDataParam in the same
+ * Expert: Expert Mode, Specifier is required splitParams, limit
SplitDataParam in the same
* store group
*
* @param mode
@@ -1085,11 +1085,11 @@ public class PDClient {
/**
* Migrate partitions in manual mode
- * //Working mode
- * // Auto:Automatic transfer to the same number of partitions per Store
- * // Expert:Expert Mode,Specifier is required transferParams
+ * // Working mode
+ * // Auto: Automatic transfer to the same number of partitions per Store
+ * // Expert: Expert Mode, Specifier is required transferParams
*
- * @param params Designation transferParams, expert mode,request source
store / target store
+ * @param params Designation transferParams, expert mode, request source
store / target store
* in the same store group
* @throws PDException
*/
@@ -1228,7 +1228,7 @@ public class PDClient {
* Used for the store's shard list rebuild
*
* @param groupId shard group id
- * @param shards shard list,delete when shards size is 0
+ * @param shards shard list, delete when shards size is 0
*/
public void updateShardGroupOp(int groupId, List<Metapb.Shard> shards)
throws PDException {
Pdpb.ChangeShardRequest request = Pdpb.ChangeShardRequest.newBuilder()
diff --git
a/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionService.java
b/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionService.java
index 6ec779d27..9f4dda31f 100644
---
a/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionService.java
+++
b/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/PartitionService.java
@@ -145,7 +145,7 @@ public class PartitionService implements RaftStateListener {
partition, 0))
.build();
log.debug(
- "{} Partition get code = {}, partition id = {}, start = {},
end = {}, leader = {}",
+ "{} Partition get code = {}, partition id = {}, start = {},
end = {}, leader = {}",
graphName, (code), partition.getId(), partition.getStartKey(),
partition.getEndKey(), partShard.getLeader());
@@ -264,7 +264,7 @@ public class PartitionService implements RaftStateListener {
}
/**
- * compute graph partition id。partition gap * store group id + offset
+ * compute graph partition id, partition gap * store group id + offset
*
* @param graph graph
* @param offset offset
@@ -764,7 +764,7 @@ public class PartitionService implements RaftStateListener {
}
/**
- * transfer leader to other shard 。
+ * transfer leader to other shard
* Just transfer a partition
*/
public void transferLeader(Integer partId, Metapb.Shard shard) {
@@ -862,7 +862,7 @@ public class PartitionService implements RaftStateListener {
var groupSize = partitions.size() / toCount; // merge group size
// 0~12 to 4 partitions
- // scheme:0,1,2 => 0, 3,4,5 -> 1, 6,7,8 ->2, 9,10,11 -> 3
+ // scheme: 0,1,2 => 0, 3,4,5 => 1, 6,7,8 => 2, 9,10,11 => 3
// Ensure the continuity of partitions
for (int i = 0; i < toCount; i++) {
var startKey = partitions.get(i * groupSize).getStartKey();
@@ -1010,7 +1010,7 @@ public class PartitionService implements
RaftStateListener {
*/
protected void fireChangeShard(Metapb.Partition partition,
List<Metapb.Shard> shards,
ConfChangeType changeType) {
- log.info("fireChangeShard partition: {}-{}, changeType:{} {}",
partition.getGraphName(),
+ log.info("fireChangeShard partition: {}-{}, changeType: {} {}",
partition.getGraphName(),
partition.getId(), changeType, shards);
instructionListeners.forEach(cmd -> {
try {
@@ -1037,7 +1037,7 @@ public class PartitionService implements
RaftStateListener {
* @param partition
*/
protected void fireSplitPartition(Metapb.Partition partition,
SplitPartition splitPartition) {
- log.info("fireSplitPartition partition: {}-{}, split :{}",
+ log.info("fireSplitPartition partition: {}-{}, split: {}",
partition.getGraphName(), partition.getId(), splitPartition);
instructionListeners.forEach(cmd -> {
try {
@@ -1052,7 +1052,7 @@ public class PartitionService implements
RaftStateListener {
* Send a Leader Switchover message
*/
protected void fireTransferLeader(Metapb.Partition partition,
TransferLeader transferLeader) {
- log.info("fireTransferLeader partition: {}-{}, leader :{}",
+ log.info("fireTransferLeader partition: {}-{}, leader: {}",
partition.getGraphName(), partition.getId(), transferLeader);
instructionListeners.forEach(cmd -> {
try {
@@ -1067,7 +1067,7 @@ public class PartitionService implements
RaftStateListener {
* Send a message to the partition to move data
*
* @param partition Original partition
- * @param movePartition Target partition,contains key range
+ * @param movePartition Target partition, contains key range
*/
protected void fireMovePartition(Metapb.Partition partition, MovePartition
movePartition) {
log.info("fireMovePartition partition: {} -> {}",
@@ -1159,8 +1159,8 @@ public class PartitionService implements
RaftStateListener {
/**
* When all migration subtasks succeed:
* 1. Send cleanup source partition directives
- * 2. Set up target online,renewal key range, renewal graph partition count
- * 3. delete move task,mission ended
+ * 2. Set up target online, renewal key range, renewal graph partition
count
+ * 3. delete move task, mission ended
*
* @param subTasks all move sub tasks
* @param graphName graph name
@@ -1238,7 +1238,7 @@ public class PartitionService implements
RaftStateListener {
fireCleanPartition(source, cleanPartition);
}
- // renewal key range, Local updates,client renewal
+ // renewal key range, Local updates, client renewal
// updatePartition(targetPartitions);
// renewal target Partition status, source may be deleted, so do not
process
diff --git
a/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreNodeService.java
b/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreNodeService.java
index 50d810a51..9ca248022 100644
---
a/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreNodeService.java
+++
b/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/StoreNodeService.java
@@ -575,7 +575,7 @@ public class StoreNodeService {
}
/**
- * According to the number of partitions,distribute group shard
+ * According to the number of partitions, distribute group shard
*
* @param groups list of (partition id, count)
* @return total groups