Revert "[Segment Replication] Introduce primary weight factor for pri…

…mary shards distribution (#6017) (#6161)" This reverts commit 2e3e1ed.
opensearch-project · Feb 22, 2023 · f7d2e9c · f7d2e9c
1 parent 67d8765
commit f7d2e9c
Show file tree

Hide file tree

Showing 15 changed files with 24 additions and 852 deletions.
diff --git a/libs/common/src/main/java/org/opensearch/common/collect/Triplet.java b/libs/common/src/main/java/org/opensearch/common/collect/Triplet.java
diff --git a/...alClusterTest/java/org/opensearch/indices/replication/SegmentReplicationAllocationIT.java b/...alClusterTest/java/org/opensearch/indices/replication/SegmentReplicationAllocationIT.java
diff --git a/server/src/main/java/org/opensearch/cluster/routing/RoutingNode.java b/server/src/main/java/org/opensearch/cluster/routing/RoutingNode.java
@@ -329,23 +329,6 @@ public List<ShardRouting> shardsWithState(ShardRoutingState... states) {
         return shards;
     }
 
-    /**
-     * Determine the primary shards of an index with a specific state
-     * @param states set of states which should be listed
-     * @return a list of shards
-     */
-    public List<ShardRouting> primaryShardsWithState(ShardRoutingState... states) {
-        List<ShardRouting> shards = new ArrayList<>();
-        for (ShardRouting shardEntry : this) {
-            for (ShardRoutingState state : states) {
-                if (shardEntry.state() == state && shardEntry.primary() == true) {
-                    shards.add(shardEntry);
-                }
-            }
-        }
-        return shards;
-    }
-
     /**
      * Determine the shards of an index with a specific state
      * @param index id of the index