diff options
Diffstat (limited to 'clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/ClusterStatsChangeTracker.java')
-rw-r--r-- | clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/ClusterStatsChangeTracker.java | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/ClusterStatsChangeTracker.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/ClusterStatsChangeTracker.java index 68f19c721d9..3b9de562ea6 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/ClusterStatsChangeTracker.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/ClusterStatsChangeTracker.java @@ -1,10 +1,9 @@ -// Copyright 2018 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. +// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.vespa.clustercontroller.core; import com.yahoo.document.FixedBucketSpaces; import java.util.HashMap; -import java.util.Iterator; import java.util.Map; /** @@ -32,8 +31,8 @@ public class ClusterStatsChangeTracker { public void syncAggregatedStats() { prevMayHaveMergesPending = new HashMap<>(); - for (Iterator<ContentNodeStats> itr = aggregatedStats.getStats().iterator(); itr.hasNext(); ) { - int nodeIndex = itr.next().getNodeIndex(); + for (ContentNodeStats contentNodeStats : aggregatedStats.getStats()) { + int nodeIndex = contentNodeStats.getNodeIndex(); prevMayHaveMergesPending.put(nodeIndex, mayHaveMergesPendingInGlobalSpace(nodeIndex)); } } @@ -48,8 +47,8 @@ public class ClusterStatsChangeTracker { if (!aggregatedStats.hasUpdatesFromAllDistributors()) { return false; } - for (Iterator<ContentNodeStats> itr = aggregatedStats.getStats().iterator(); itr.hasNext(); ) { - int nodeIndex = itr.next().getNodeIndex(); + for (ContentNodeStats contentNodeStats : aggregatedStats.getStats()) { + int nodeIndex = contentNodeStats.getNodeIndex(); boolean currValue = mayHaveMergesPendingInGlobalSpace(nodeIndex); Boolean prevValue = prevMayHaveMergesPendingInGlobalSpace(nodeIndex); if (prevValue != null) { |