Remove hash collisions reporting

core/trino-main/src/main/java/io/trino/operator/BigintGroupByHash.java

@@ -39,7 +39,6 @@
 import static io.trino.spi.StandardErrorCode.GENERIC_INSUFFICIENT_RESOURCES;
 import static io.trino.spi.type.BigintType.BIGINT;
 import static io.trino.type.TypeUtils.NULL_HASH_CODE;
-import static io.trino.util.HashCollisionsEstimator.estimateNumberOfHashCollisions;
 import static it.unimi.dsi.fastutil.HashCommon.arraySize;
 import static it.unimi.dsi.fastutil.HashCommon.murmurHash3;
 import static java.lang.Math.min;
@@ -75,8 +74,6 @@ public class BigintGroupByHash
 
     private int nextGroupId;
     private DictionaryLookBack dictionaryLookBack;
-    private long hashCollisions;
-    private double expectedHashCollisions;
 
     // reserve enough memory before rehash
     private final UpdateMemory updateMemory;
@@ -116,18 +113,6 @@ public long getEstimatedSize()
                 preallocatedMemoryInBytes;
     }
 
-    @Override
-    public long getHashCollisions()
-    {
-        return hashCollisions;
-    }
-
-    @Override
-    public double getExpectedHashCollisions()
-    {
-        return expectedHashCollisions + estimateNumberOfHashCollisions(getGroupCount(), hashCapacity);
-    }
-
     @Override
     public List<Type> getTypes()
     {
@@ -259,7 +244,6 @@ private int putIfAbsent(int position, Block block)
 
             // increment position and mask to handle wrap around
             hashPosition = (hashPosition + 1) & mask;
-            hashCollisions++;
         }
 
         return addNewGroup(hashPosition, value);
@@ -298,8 +282,6 @@ private boolean tryRehash()
         }
         preallocatedMemoryInBytes = 0;
 
-        expectedHashCollisions += estimateNumberOfHashCollisions(getGroupCount(), hashCapacity);
-
         int newMask = newCapacity - 1;
         long[] newValues = new long[newCapacity];
         int[] newGroupIds = new int[newCapacity];
@@ -315,7 +297,6 @@ private boolean tryRehash()
                 // find an empty slot for the address
                 while (newGroupIds[hashPosition] != -1) {
                     hashPosition = (hashPosition + 1) & newMask;
-                    hashCollisions++;
                 }
 
                 // record the mapping

core/trino-main/src/main/java/io/trino/operator/GroupByHash.java

@@ -60,10 +60,6 @@ static GroupByHash createGroupByHash(
 
     long getEstimatedSize();
 
-    long getHashCollisions();
-
-    double getExpectedHashCollisions();
-
     List<Type> getTypes();
 
     int getGroupCount();

core/trino-main/src/main/java/io/trino/operator/HashAggregationOperator.java

@@ -281,7 +281,6 @@ public OperatorFactory duplicate()
     private final BlockTypeOperators blockTypeOperators;
 
     private final List<Type> types;
-    private final HashCollisionsCounter hashCollisionsCounter;
 
     private HashAggregationBuilder aggregationBuilder;
     private final LocalMemoryContext memoryContext;
@@ -339,8 +338,6 @@ private HashAggregationOperator(
         this.spillerFactory = requireNonNull(spillerFactory, "spillerFactory is null");
         this.joinCompiler = requireNonNull(joinCompiler, "joinCompiler is null");
         this.blockTypeOperators = requireNonNull(blockTypeOperators, "blockTypeOperators is null");
-        this.hashCollisionsCounter = new HashCollisionsCounter(operatorContext);
-        operatorContext.setInfoSupplier(hashCollisionsCounter);
 
         this.memoryContext = operatorContext.localUserMemoryContext();
     }
@@ -534,7 +531,6 @@ private void closeAggregationBuilder()
     {
         outputPages = null;
         if (aggregationBuilder != null) {
-            aggregationBuilder.recordHashCollisions(hashCollisionsCounter);
             aggregationBuilder.close();
             // aggregationBuilder.close() will release all memory reserved in memory accounting.
             // The reference must be set to null afterwards to avoid unaccounted memory.

core/trino-main/src/main/java/io/trino/operator/MultiChannelGroupByHash.java

@@ -44,7 +44,6 @@
 import static io.trino.spi.StandardErrorCode.GENERIC_INSUFFICIENT_RESOURCES;
 import static io.trino.spi.type.BigintType.BIGINT;
 import static io.trino.sql.gen.JoinCompiler.PagesHashStrategyFactory;
-import static io.trino.util.HashCollisionsEstimator.estimateNumberOfHashCollisions;
 import static it.unimi.dsi.fastutil.HashCommon.arraySize;
 import static it.unimi.dsi.fastutil.HashCommon.murmurHash3;
 import static java.lang.Math.min;
@@ -89,8 +88,6 @@ public class MultiChannelGroupByHash
 
     private int nextGroupId;
     private DictionaryLookBack dictionaryLookBack;
-    private long hashCollisions;
-    private double expectedHashCollisions;
 
     // reserve enough memory before rehash
     private final UpdateMemory updateMemory;
@@ -178,18 +175,6 @@ public long getEstimatedSize()
                 (dictionaryLookBack != null ? dictionaryLookBack.getRetainedSizeInBytes() : 0);
     }
 
-    @Override
-    public long getHashCollisions()
-    {
-        return hashCollisions;
-    }
-
-    @Override
-    public double getExpectedHashCollisions()
-    {
-        return expectedHashCollisions + estimateNumberOfHashCollisions(getGroupCount(), hashCapacity);
-    }
-
     @Override
     public List<Type> getTypes()
     {
@@ -297,7 +282,6 @@ private int putIfAbsent(int position, Page page, long rawHash)
             }
             // increment position and mask to handle wrap around
             hashPosition = (hashPosition + 1) & mask;
-            hashCollisions++;
         }
 
         // did we find an existing group?
@@ -381,8 +365,6 @@ private boolean tryRehash()
         }
         preallocatedMemoryInBytes = 0;
 
-        expectedHashCollisions += estimateNumberOfHashCollisions(getGroupCount(), hashCapacity);
-
         int newMask = newCapacity - 1;
         byte[] rawHashes = new byte[newCapacity];
         int[] newGroupIdByHash = new int[newCapacity];
@@ -400,7 +382,6 @@ private boolean tryRehash()
             int pos = getHashPosition(rawHash, newMask);
             while (newGroupIdByHash[pos] != -1) {
                 pos = (pos + 1) & newMask;
-                hashCollisions++;
             }
 
             // record the mapping

core/trino-main/src/main/java/io/trino/operator/NoChannelGroupByHash.java

@@ -38,18 +38,6 @@ public long getEstimatedSize()
         return INSTANCE_SIZE;
     }
 
-    @Override
-    public long getHashCollisions()
-    {
-        return 0;
-    }
-
-    @Override
-    public double getExpectedHashCollisions()
-    {
-        return 0;
-    }
-
     @Override
     public List<Type> getTypes()
     {

core/trino-main/src/main/java/io/trino/operator/OperatorInfo.java

@@ -28,7 +28,6 @@
         @JsonSubTypes.Type(value = LocalExchangeBufferInfo.class, name = "localExchangeBuffer"),
         @JsonSubTypes.Type(value = TableFinishInfo.class, name = "tableFinish"),
         @JsonSubTypes.Type(value = SplitOperatorInfo.class, name = "splitOperator"),
-        @JsonSubTypes.Type(value = HashCollisionsInfo.class, name = "hashCollisionsInfo"),
         @JsonSubTypes.Type(value = PartitionedOutputInfo.class, name = "partitionedOutput"),
         @JsonSubTypes.Type(value = JoinOperatorInfo.class, name = "joinOperatorInfo"),
         @JsonSubTypes.Type(value = WindowInfo.class, name = "windowInfo"),

core/trino-main/src/main/java/io/trino/operator/aggregation/builder/HashAggregationBuilder.java

@@ -14,7 +14,6 @@
 package io.trino.operator.aggregation.builder;
 
 import com.google.common.util.concurrent.ListenableFuture;
-import io.trino.operator.HashCollisionsCounter;
 import io.trino.operator.Work;
 import io.trino.operator.WorkProcessor;
 import io.trino.spi.Page;
@@ -30,8 +29,6 @@ public interface HashAggregationBuilder
 
     void updateMemory();
 
-    void recordHashCollisions(HashCollisionsCounter hashCollisionsCounter);
-
     @Override
     void close();
 

core/trino-main/src/main/java/io/trino/operator/aggregation/builder/InMemoryHashAggregationBuilder.java

@@ -20,7 +20,6 @@
 import io.airlift.units.DataSize;
 import io.trino.array.IntBigArray;
 import io.trino.operator.GroupByHash;
-import io.trino.operator.HashCollisionsCounter;
 import io.trino.operator.OperatorContext;
 import io.trino.operator.TransformWork;
 import io.trino.operator.UpdateMemory;
@@ -161,22 +160,6 @@ public boolean isFull()
         return full;
     }
 
-    @Override
-    public void recordHashCollisions(HashCollisionsCounter hashCollisionsCounter)
-    {
-        hashCollisionsCounter.recordHashCollision(groupByHash.getHashCollisions(), groupByHash.getExpectedHashCollisions());
-    }
-
-    public long getHashCollisions()
-    {
-        return groupByHash.getHashCollisions();
-    }
-
-    public double getExpectedHashCollisions()
-    {
-        return groupByHash.getExpectedHashCollisions();
-    }
-
     @Override
     public ListenableFuture<Void> startMemoryRevoke()
     {

core/trino-main/src/main/java/io/trino/operator/aggregation/builder/SpillableHashAggregationBuilder.java

@@ -18,7 +18,6 @@
 import com.google.common.util.concurrent.ListenableFuture;
 import io.airlift.units.DataSize;
 import io.trino.memory.context.LocalMemoryContext;
-import io.trino.operator.HashCollisionsCounter;
 import io.trino.operator.MergeHashSort;
 import io.trino.operator.OperatorContext;
 import io.trino.operator.Work;
@@ -70,8 +69,6 @@ public class SpillableHashAggregationBuilder
     // todo get rid of that and only use revocable memory
     private long emptyHashAggregationBuilderSize;
 
-    private long hashCollisions;
-    private double expectedHashCollisions;
     private boolean producingOutput;
 
     public SpillableHashAggregationBuilder(
@@ -131,14 +128,6 @@ public void updateMemory()
         }
     }
 
-    @Override
-    public void recordHashCollisions(HashCollisionsCounter hashCollisionsCounter)
-    {
-        hashCollisionsCounter.recordHashCollision(hashCollisions, expectedHashCollisions);
-        hashCollisions = 0;
-        expectedHashCollisions = 0;
-    }
-
     @Override
     public boolean isFull()
     {
@@ -321,8 +310,6 @@ private WorkProcessor<Page> mergeSortedPages(WorkProcessor<Page> sortedPages, lo
     private void rebuildHashAggregationBuilder()
     {
         if (hashAggregationBuilder != null) {
-            hashCollisions += hashAggregationBuilder.getHashCollisions();
-            expectedHashCollisions += hashAggregationBuilder.getExpectedHashCollisions();
             hashAggregationBuilder.close();
         }