summaryrefslogtreecommitdiffstats
path: root/vdslib
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2023-03-28 19:33:41 +0200
committerHarald Musum <musum@yahooinc.com>2023-03-28 19:33:41 +0200
commit198bdb42cc17e8948da7479939012372be13c8dc (patch)
treeb0fd4f7213109ba18d4f3560122e01485614eba7 /vdslib
parenta9646ed0608bf59ed831617eec559a10723fe7fa (diff)
Don't use record, fails when running system tests
Diffstat (limited to 'vdslib')
-rw-r--r--vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java24
1 files changed, 21 insertions, 3 deletions
diff --git a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java
index 9eb88661002..9a451ac56ec 100644
--- a/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java
+++ b/vdslib/src/main/java/com/yahoo/vdslib/distribution/Distribution.java
@@ -26,7 +26,15 @@ import java.util.concurrent.atomic.AtomicReference;
public class Distribution {
- private record Config(Group nodeGraph, int redundancy) { }
+ private static class Config {
+ Config(Group nodeGraph, int redundancy) {
+ this.nodeGraph = nodeGraph;
+ this.redundancy = redundancy;
+ }
+
+ private final Group nodeGraph;
+ private final int redundancy;
+ }
private ConfigSubscriber configSub;
private final AtomicReference<Config> config = new AtomicReference<>(new Config(null, 1));
@@ -201,10 +209,20 @@ public class Distribution {
}
}
- private record ScoredNode(int index, double score) {
+ private static class ScoredNode {
+ final double score;
+ final int index;
+
+ ScoredNode(int index, double score) {
+ this.score = score;
+ this.index = index;
+ }
boolean valid() { return index != -1; }
- static ScoredNode makeInvalid() { return new ScoredNode(-1, 0.0); }
+
+ static ScoredNode makeInvalid() {
+ return new ScoredNode(-1, 0.0);
+ }
}
private static boolean allDistributorsDown(Group g, ClusterState clusterState) {