diff --git a/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsReader.java b/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsReader.java index 3d6f7f24a1600..5ed37ac6b20cf 100644 --- a/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsReader.java +++ b/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsReader.java @@ -352,8 +352,9 @@ private static void score( public PostingVisitor getPostingVisitor(FieldInfo fieldInfo, IndexInput indexInput, float[] target, Bits acceptDocs) throws IOException { FieldEntry entry = fields.get(fieldInfo.number); - final int maxPostingListSize = indexInput.readVInt(); - return new MemorySegmentPostingsVisitor(target, indexInput, entry, fieldInfo, maxPostingListSize, acceptDocs); + // max postings list size, no longer utilized + indexInput.readVInt(); + return new MemorySegmentPostingsVisitor(target, indexInput, entry, fieldInfo, acceptDocs); } @Override @@ -393,14 +394,8 @@ private static class MemorySegmentPostingsVisitor implements PostingVisitor { final float[] correctiveValues = new float[3]; final long quantizedVectorByteSize; - MemorySegmentPostingsVisitor( - float[] target, - IndexInput indexInput, - FieldEntry entry, - FieldInfo fieldInfo, - int maxPostingListSize, - Bits acceptDocs - ) throws IOException { + MemorySegmentPostingsVisitor(float[] target, IndexInput indexInput, FieldEntry entry, FieldInfo fieldInfo, Bits acceptDocs) + throws IOException { this.target = target; this.indexInput = indexInput; this.entry = entry; diff --git a/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsWriter.java b/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsWriter.java index 7f77f0de22bc7..7a46335effbcf 100644 --- a/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsWriter.java +++ b/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/ES920DiskBBQVectorsWriter.java @@ -531,8 +531,6 @@ public int size() { public CentroidAssignments calculateCentroids(FieldInfo fieldInfo, FloatVectorValues floatVectorValues, float[] globalCentroid) throws IOException { - long nanoTime = System.nanoTime(); - // TODO: consider hinting / bootstrapping hierarchical kmeans with the prior segments centroids CentroidAssignments centroidAssignments = buildCentroidAssignments(floatVectorValues, vectorPerCluster); float[][] centroids = centroidAssignments.centroids(); @@ -549,7 +547,6 @@ public CentroidAssignments calculateCentroids(FieldInfo fieldInfo, FloatVectorVa } if (logger.isDebugEnabled()) { - logger.debug("calculate centroids and assign vectors time ms: {}", (System.nanoTime() - nanoTime) / 1000000.0); logger.debug("final centroid count: {}", centroids.length); } return centroidAssignments; diff --git a/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/next/ESNextDiskBBQVectorsWriter.java b/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/next/ESNextDiskBBQVectorsWriter.java index 13d6fb4cd93da..8ca99101d7503 100644 --- a/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/next/ESNextDiskBBQVectorsWriter.java +++ b/server/src/main/java/org/elasticsearch/index/codec/vectors/diskbbq/next/ESNextDiskBBQVectorsWriter.java @@ -519,8 +519,6 @@ public int size() { public CentroidAssignments calculateCentroids(FieldInfo fieldInfo, FloatVectorValues floatVectorValues, float[] globalCentroid) throws IOException { - long nanoTime = System.nanoTime(); - // TODO: consider hinting / bootstrapping hierarchical kmeans with the prior segments centroids CentroidAssignments centroidAssignments = buildCentroidAssignments(floatVectorValues, vectorPerCluster); float[][] centroids = centroidAssignments.centroids(); @@ -537,7 +535,6 @@ public CentroidAssignments calculateCentroids(FieldInfo fieldInfo, FloatVectorVa } if (logger.isDebugEnabled()) { - logger.debug("calculate centroids and assign vectors time ms: {}", (System.nanoTime() - nanoTime) / 1000000.0); logger.debug("final centroid count: {}", centroids.length); } return centroidAssignments;