[Composite Terms Aggregation] Re-use slot objects for look-ups

server/src/main/java/org/opensearch/search/aggregations/bucket/composite/CompositeValuesCollectorQueue.java

@@ -60,6 +60,11 @@ private class Slot {
             this.value = initial;
         }
 
+        // This is to be only for reusable slot
+        public void set(int newValue) {
+            this.value = newValue;
+        }
+
         @Override
         public boolean equals(Object o) {
             if (this == o) return true;
@@ -82,6 +87,14 @@ public int hashCode() {
     private final Map<Slot, Integer> map; // to quickly find the slot for a value
     private final SingleDimensionValuesSource<?>[] arrays;
 
+    /**
+     * A reusable, flyweight Slot instance to avoid object allocation and reduce GC pressure
+     * during map lookups in the high-frequency collect() path. This object is NOT
+     * thread-safe, but is safe here because each collector instance is confined to a
+     * single thread.
+     */
+    private final Slot reusableSlot = new Slot(0);
+
     private LongArray docCounts;
     private boolean afterKeyIsSet = false;
 
@@ -125,7 +138,8 @@ boolean isFull() {
      * the slot if the candidate is already in the queue or null if the candidate is not present.
      */
     Integer getCurrentSlot() {
-        return map.get(new Slot(CANDIDATE_SLOT));
+            reusableSlot.set(CANDIDATE_SLOT); // Update the state of the reusable slot
+            return map.get(reusableSlot);     // Use the single reusable slot instance for the lookup
     }
 
     /**
@@ -322,7 +336,8 @@ boolean addIfCompetitive(int indexSortSourcePrefix, long inc) {
         if (size() >= maxSize) {
             // the queue is full, we replace the last key with this candidate
             int slot = pop();
-            map.remove(new Slot(slot));
+            reusableSlot.set(slot);          // Use reusable for remove
+            map.remove(reusableSlot);
             // and we recycle the deleted slot
             newSlot = slot;
         } else {