Make Blocks and Vectors Releasable

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/BooleanArrayBlock.java

@@ -95,4 +95,9 @@ public String toString() {
             + Arrays.toString(values)
             + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/BooleanArrayVector.java

@@ -77,4 +77,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", values=" + Arrays.toString(values) + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/BooleanVectorBlock.java

@@ -71,4 +71,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[vector=" + vector + "]";
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/BytesRefArrayBlock.java

@@ -96,4 +96,9 @@ public String toString() {
             + values.size()
             + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/BytesRefArrayVector.java

@@ -10,6 +10,7 @@
 import org.apache.lucene.util.BytesRef;
 import org.apache.lucene.util.RamUsageEstimator;
 import org.elasticsearch.common.util.BytesRefArray;
+import org.elasticsearch.core.Releasables;
 
 /**
  * Vector implementation that stores an array of BytesRef values.
@@ -77,4 +78,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ']';
     }
+
+    @Override
+    public void close() {
+        Releasables.close(values);
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/BytesRefVectorBlock.java

@@ -72,4 +72,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[vector=" + vector + "]";
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/ConstantBooleanVector.java

@@ -70,4 +70,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", value=" + value + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/ConstantBytesRefVector.java

@@ -71,4 +71,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", value=" + value + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/ConstantDoubleVector.java

@@ -70,4 +70,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", value=" + value + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/ConstantIntVector.java

@@ -70,4 +70,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", value=" + value + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/ConstantLongVector.java

@@ -70,4 +70,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", value=" + value + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/DoubleArrayBlock.java

@@ -95,4 +95,9 @@ public String toString() {
             + Arrays.toString(values)
             + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/DoubleArrayVector.java

@@ -77,4 +77,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", values=" + Arrays.toString(values) + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/DoubleVectorBlock.java

@@ -71,4 +71,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[vector=" + vector + "]";
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterBooleanBlock.java

@@ -122,4 +122,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(']');
         }
     }
+
+    @Override
+    public void close() {
+        block.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterBooleanVector.java

@@ -88,4 +88,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(getBoolean(i));
         }
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterBytesRefBlock.java

@@ -125,4 +125,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(']');
         }
     }
+
+    @Override
+    public void close() {
+        block.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterBytesRefVector.java

@@ -89,4 +89,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(getBytesRef(i, new BytesRef()));
         }
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterDoubleBlock.java

@@ -122,4 +122,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(']');
         }
     }
+
+    @Override
+    public void close() {
+        block.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterDoubleVector.java

@@ -88,4 +88,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(getDouble(i));
         }
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterIntBlock.java

@@ -122,4 +122,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(']');
         }
     }
+
+    @Override
+    public void close() {
+        block.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterIntVector.java

@@ -88,4 +88,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(getInt(i));
         }
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterLongBlock.java

@@ -122,4 +122,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(']');
         }
     }
+
+    @Override
+    public void close() {
+        block.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/FilterLongVector.java

@@ -88,4 +88,9 @@ private void appendValues(StringBuilder sb) {
             sb.append(getLong(i));
         }
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/IntArrayBlock.java

@@ -95,4 +95,9 @@ public String toString() {
             + Arrays.toString(values)
             + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/IntArrayVector.java

@@ -77,4 +77,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", values=" + Arrays.toString(values) + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/IntVectorBlock.java

@@ -71,4 +71,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[vector=" + vector + "]";
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/LongArrayBlock.java

@@ -95,4 +95,9 @@ public String toString() {
             + Arrays.toString(values)
             + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/LongArrayVector.java

@@ -77,4 +77,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[positions=" + getPositionCount() + ", values=" + Arrays.toString(values) + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }

x-pack/plugin/esql/compute/src/main/generated-src/org/elasticsearch/compute/data/LongVectorBlock.java

@@ -71,4 +71,9 @@ public int hashCode() {
     public String toString() {
         return getClass().getSimpleName() + "[vector=" + vector + "]";
     }
+
+    @Override
+    public void close() {
+        vector.close();
+    }
 }

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/Block.java

@@ -10,6 +10,7 @@
 import org.apache.lucene.util.Accountable;
 import org.elasticsearch.common.io.stream.NamedWriteable;
 import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
+import org.elasticsearch.core.Releasable;
 
 import java.util.List;
 
@@ -31,7 +32,7 @@
  *
  * <p> Block are immutable and can be passed between threads.
  */
-public interface Block extends Accountable, NamedWriteable {
+public interface Block extends Accountable, NamedWriteable, Releasable {
 
     /**
      * {@return an efficient dense single-value view of this block}.

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/ConstantNullBlock.java

@@ -119,6 +119,11 @@ public String toString() {
         return "ConstantNullBlock[positions=" + getPositionCount() + "]";
     }
 
+    @Override
+    public void close() {
+        // no-op
+    }
+
     static class Builder implements Block.Builder {
         private int positionCount;
 

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/DocBlock.java

@@ -9,6 +9,7 @@
 
 import org.apache.lucene.util.RamUsageEstimator;
 import org.elasticsearch.common.io.stream.StreamOutput;
+import org.elasticsearch.core.Releasables;
 
 import java.io.IOException;
 
@@ -56,6 +57,11 @@ public long ramBytesUsed() {
         return BASE_RAM_BYTES_USED + RamUsageEstimator.sizeOf(vector);
     }
 
+    @Override
+    public void close() {
+        Releasables.close(vector);
+    }
+
     /**
      * A builder the for {@link DocBlock}.
      */

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/DocVector.java

@@ -9,6 +9,7 @@
 
 import org.apache.lucene.util.IntroSorter;
 import org.apache.lucene.util.RamUsageEstimator;
+import org.elasticsearch.core.Releasables;
 
 /**
  * {@link Vector} where each entry references a lucene document.
@@ -198,4 +199,9 @@ public static long ramBytesEstimated(
     public long ramBytesUsed() {
         return ramBytesEstimated(shards, segments, docs, shardSegmentDocMapForwards, shardSegmentDocMapBackwards);
     }
+
+    @Override
+    public void close() {
+        Releasables.close(shards, segments, docs);
+    }
 }

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/Vector.java

@@ -8,11 +8,12 @@
 package org.elasticsearch.compute.data;
 
 import org.apache.lucene.util.Accountable;
+import org.elasticsearch.core.Releasable;
 
 /**
  * A dense Vector of single values.
  */
-public interface Vector extends Accountable {
+public interface Vector extends Accountable, Releasable {
 
     /**
      * {@return Returns a Block view over this vector.}

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/data/X-ArrayBlock.java.st

@@ -121,4 +121,9 @@ $else$
 $endif$
             + ']';
     }
+
+    @Override
+    public void close() {
+        // no-op
+    }
 }