From 9d3a45c33b655b770f16bc44036b245e4c2a873d Mon Sep 17 00:00:00 2001 From: Peng Junzhi <201250214@smail.nju.edu.cn> Date: Sun, 4 Aug 2024 17:22:48 +0800 Subject: [PATCH] fix --- .../org/apache/hugegraph/store/cli/loader/HgThread2DB.java | 6 +++--- .../org/apache/hugegraph/store/PartitionStateListener.java | 4 +--- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/hugegraph-store/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/loader/HgThread2DB.java b/hugegraph-store/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/loader/HgThread2DB.java index f5cb9fe73b..5ab95cc249 100644 --- a/hugegraph-store/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/loader/HgThread2DB.java +++ b/hugegraph-store/hg-store-cli/src/main/java/org/apache/hugegraph/store/cli/loader/HgThread2DB.java @@ -52,7 +52,7 @@ /** * use pd, support raft - * Read the file and go into multi threaded warehouse + * Read the file and go into multi thread warehouse */ @Slf4j public class HgThread2DB { @@ -465,9 +465,9 @@ private void queryAnd2Queue() { /** * Multi -thread query * - * @param Point Start Query Point, Followed Up According to this PointValue as the next + * @param point Start Query Point, Followed Up According to this PointValue as the next * query condition to iterate - * @param Scancount allows the number of threads to start + * @param scanCount allows the number of threads to start * @throws IOException * @throws InterruptedException */ diff --git a/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/PartitionStateListener.java b/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/PartitionStateListener.java index 8fd5e129be..e433aea75e 100644 --- a/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/PartitionStateListener.java +++ b/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/PartitionStateListener.java @@ -24,11 +24,9 @@ import org.apache.hugegraph.store.meta.PartitionRole; public interface PartitionStateListener { - - // 分区角色发生改变 + void partitionRoleChanged(Partition partition, PartitionRole newRole); - // 分区发生改变 void partitionShardChanged(Partition partition, List oldShards, List newShards); }