Allow VectorFixedBuilder to become released without build (elastic#10…

…0567) VectorFixedBuilder can be closed without calling build and we should move its state to released in this case.
masseyke · Oct 10, 2023 · f313479 · f313479
1 parent a8d79b3
commit f313479
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 0 deletions.
diff --git a/...pute/src/main/generated-src/org/elasticsearch/compute/data/BooleanVectorFixedBuilder.java b/...pute/src/main/generated-src/org/elasticsearch/compute/data/BooleanVectorFixedBuilder.java
@@ -69,6 +69,7 @@ public BooleanVector build() {
     public void close() {
         if (nextIndex >= 0) {
             // If nextIndex < 0 we've already built the vector
+            nextIndex = -1;
             blockFactory.adjustBreaker(-preAdjustedBytes, false);
         }
     }

diff --git a/...mpute/src/main/generated-src/org/elasticsearch/compute/data/DoubleVectorFixedBuilder.java b/...mpute/src/main/generated-src/org/elasticsearch/compute/data/DoubleVectorFixedBuilder.java
@@ -69,6 +69,7 @@ public DoubleVector build() {
     public void close() {
         if (nextIndex >= 0) {
             // If nextIndex < 0 we've already built the vector
+            nextIndex = -1;
             blockFactory.adjustBreaker(-preAdjustedBytes, false);
         }
     }

diff --git a/.../compute/src/main/generated-src/org/elasticsearch/compute/data/IntVectorFixedBuilder.java b/.../compute/src/main/generated-src/org/elasticsearch/compute/data/IntVectorFixedBuilder.java
@@ -69,6 +69,7 @@ public IntVector build() {
     public void close() {
         if (nextIndex >= 0) {
             // If nextIndex < 0 we've already built the vector
+            nextIndex = -1;
             blockFactory.adjustBreaker(-preAdjustedBytes, false);
         }
     }

diff --git a/...compute/src/main/generated-src/org/elasticsearch/compute/data/LongVectorFixedBuilder.java b/...compute/src/main/generated-src/org/elasticsearch/compute/data/LongVectorFixedBuilder.java
@@ -69,6 +69,7 @@ public LongVector build() {
     public void close() {
         if (nextIndex >= 0) {
             // If nextIndex < 0 we've already built the vector
+            nextIndex = -1;
             blockFactory.adjustBreaker(-preAdjustedBytes, false);
         }
     }

diff --git a/...in/esql/compute/src/main/java/org/elasticsearch/compute/data/X-VectorFixedBuilder.java.st b/...in/esql/compute/src/main/java/org/elasticsearch/compute/data/X-VectorFixedBuilder.java.st
@@ -69,6 +69,7 @@ final class $Type$VectorFixedBuilder implements $Type$Vector.FixedBuilder {
     public void close() {
         if (nextIndex >= 0) {
             // If nextIndex < 0 we've already built the vector
+            nextIndex = -1;
             blockFactory.adjustBreaker(-preAdjustedBytes, false);
         }
     }