removed efSearch from HNSW

Author: normen662

fdb-extensions/src/main/java/com/apple/foundationdb/async/hnsw/HNSW.java

@@ -123,7 +123,6 @@ public static class Config {
         private final int m;
         private final int mMax;
         private final int mMax0;
-        private final int efSearch;
         private final int efConstruction;
         private final boolean extendCandidates;
         private final boolean keepPrunedConnections;
@@ -135,22 +134,20 @@ protected Config() {
             this.m = DEFAULT_M;
             this.mMax = DEFAULT_M_MAX;
             this.mMax0 = DEFAULT_M_MAX_0;
-            this.efSearch = DEFAULT_EF_SEARCH;
             this.efConstruction = DEFAULT_EF_CONSTRUCTION;
             this.extendCandidates = DEFAULT_EXTEND_CANDIDATES;
             this.keepPrunedConnections = DEFAULT_KEEP_PRUNED_CONNECTIONS;
         }
 
         protected Config(@Nonnull final Random random, @Nonnull final Metric metric, final boolean useInlining,
-                         final int m, final int mMax, final int mMax0, final int efSearch, final int efConstruction,
+                         final int m, final int mMax, final int mMax0, final int efConstruction,
                          final boolean extendCandidates, final boolean keepPrunedConnections) {
             this.random = random;
             this.metric = metric;
             this.useInlining = useInlining;
             this.m = m;
             this.mMax = mMax;
             this.mMax0 = mMax0;
-            this.efSearch = efSearch;
             this.efConstruction = efConstruction;
             this.extendCandidates = extendCandidates;
             this.keepPrunedConnections = keepPrunedConnections;
@@ -182,10 +179,6 @@ public int getMMax0() {
             return mMax0;
         }
 
-        public int getEfSearch() {
-            return efSearch;
-        }
-
         public int getEfConstruction() {
             return efConstruction;
         }
@@ -201,15 +194,15 @@ public boolean isKeepPrunedConnections() {
         @Nonnull
         public ConfigBuilder toBuilder() {
             return new ConfigBuilder(getRandom(), getMetric(), isUseInlining(), getM(), getMMax(), getMMax0(),
-                    getEfSearch(), getEfConstruction(), isExtendCandidates(), isKeepPrunedConnections());
+                    getEfConstruction(), isExtendCandidates(), isKeepPrunedConnections());
         }
 
         @Override
         @Nonnull
         public String toString() {
             return "Config[metric=" + getMetric() + "isUseInlining" + isUseInlining() + "M=" + getM() +
-                    " , MMax=" + getMMax() + " , MMax0=" + getMMax0() + ", efSearch=" + getEfSearch() +
-                    ", efConstruction=" + getEfConstruction() + ", isExtendCandidates=" + isExtendCandidates() +
+                    " , MMax=" + getMMax() + " , MMax0=" + getMMax0() + ", efConstruction=" + getEfConstruction() +
+                    ", isExtendCandidates=" + isExtendCandidates() +
                     ", isKeepPrunedConnections=" + isKeepPrunedConnections() + "]";
         }
     }
@@ -230,7 +223,6 @@ public static class ConfigBuilder {
         private int m = DEFAULT_M;
         private int mMax = DEFAULT_M_MAX;
         private int mMax0 = DEFAULT_M_MAX_0;
-        private int efSearch = DEFAULT_EF_SEARCH;
         private int efConstruction = DEFAULT_EF_CONSTRUCTION;
         private boolean extendCandidates = DEFAULT_EXTEND_CANDIDATES;
         private boolean keepPrunedConnections = DEFAULT_KEEP_PRUNED_CONNECTIONS;
@@ -239,15 +231,14 @@ public ConfigBuilder() {
         }
 
         public ConfigBuilder(@Nonnull final Random random, @Nonnull final Metric metric, final boolean useInlining,
-                             final int m, final int mMax, final int mMax0, final int efSearch, final int efConstruction,
+                             final int m, final int mMax, final int mMax0, final int efConstruction,
                              final boolean extendCandidates, final boolean keepPrunedConnections) {
             this.random = random;
             this.metric = metric;
             this.useInlining = useInlining;
             this.m = m;
             this.mMax = mMax;
             this.mMax0 = mMax0;
-            this.efSearch = efSearch;
             this.efConstruction = efConstruction;
             this.extendCandidates = extendCandidates;
             this.keepPrunedConnections = keepPrunedConnections;
@@ -314,15 +305,6 @@ public ConfigBuilder setMMax0(final int mMax0) {
             return this;
         }
 
-        public int getEfSearch() {
-            return efSearch;
-        }
-
-        public ConfigBuilder setEfSearch(final int efSearch) {
-            this.efSearch = efSearch;
-            return this;
-        }
-
         public int getEfConstruction() {
             return efConstruction;
         }
@@ -351,7 +333,7 @@ public ConfigBuilder setKeepPrunedConnections(final boolean keepPrunedConnection
         }
 
         public Config build() {
-            return new Config(getRandom(), getMetric(), isUseInlining(), getM(), getMMax(), getMMax0(), getEfSearch(),
+            return new Config(getRandom(), getMetric(), isUseInlining(), getM(), getMMax(), getMMax0(),
                     getEfConstruction(), isExtendCandidates(), isKeepPrunedConnections());
         }
     }

fdb-extensions/src/test/java/com/apple/foundationdb/async/hnsw/HNSWTest.java

@@ -68,6 +68,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.Function;
+import java.util.stream.Collectors;
 import java.util.stream.LongStream;
 import java.util.stream.Stream;
 
@@ -255,6 +256,13 @@ public void testBasicInsert(final long seed, final boolean useInlining, final bo
                 TimeUnit.NANOSECONDS.toMillis(endTs - beginTs),
                 onReadListener.getNodeCountByLayer(), onReadListener.getBytesReadByLayer(),
                 String.format(Locale.ROOT, "%.2f", recall * 100.0d));
+
+        final Set<Long> usedIds =
+                LongStream.range(0, 1000)
+                        .boxed()
+                        .collect(Collectors.toSet());
+
+        hnsw.scanLayer(db, 0, 100, node -> Assertions.assertTrue(usedIds.remove(node.getPrimaryKey().getLong(0))));
     }
 
     private int basicInsertBatch(final HNSW hnsw, final int batchSize,