rename

apache · Jan 22, 2025 · e1fb761 · e1fb761
1 parent 167e140
commit e1fb761
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
@@ -1210,7 +1210,7 @@ public TConfigNodeLocation generateLocalConfigNodeLocation() {
         new TEndPoint(getInternalAddress(), getConsensusPort()));
   }
 
-  public boolean getRegionGroupConsistency(TConsensusGroupId regionGroupId) {
+  public boolean isConsensusGroupStrongConsistency(TConsensusGroupId regionGroupId) {
     return (TConsensusGroupType.SchemaRegion.equals(regionGroupId.getType())
             && getSchemaRegionConsensusProtocolClass().equals(ConsensusFactory.RATIS_CONSENSUS))
         || (TConsensusGroupType.DataRegion.equals(regionGroupId.getType())

diff --git a/...re/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/LoadCache.java b/...re/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/LoadCache.java
@@ -169,7 +169,8 @@ private void initRegionGroupHeartbeatCache(
             regionReplicaSets.forEach(
                 regionReplicaSet -> {
                   TConsensusGroupId regionGroupId = regionReplicaSet.getRegionId();
-                  boolean isStrongConsistency = CONF.getRegionGroupConsistency(regionGroupId);
+                  boolean isStrongConsistency =
+                      CONF.isConsensusGroupStrongConsistency(regionGroupId);
                   regionGroupCacheMap.put(
                       regionGroupId,
                       new RegionGroupCache(
@@ -284,7 +285,7 @@ public void removeNodeCache(int nodeId) {
    */
   public void createRegionGroupHeartbeatCache(
       String database, TConsensusGroupId regionGroupId, Set<Integer> dataNodeIds) {
-    boolean isStrongConsistency = CONF.getRegionGroupConsistency(regionGroupId);
+    boolean isStrongConsistency = CONF.isConsensusGroupStrongConsistency(regionGroupId);
     regionGroupCacheMap.put(
         regionGroupId, new RegionGroupCache(database, dataNodeIds, isStrongConsistency));
     consensusGroupCacheMap.put(regionGroupId, new ConsensusGroupCache());