Fix nested transformer close and move shared classes (#17642)

Author: shuwenwei

…yengine/execution/schedule/queue/ID.java …db/calc/execution/schedule/queue/ID.javaiotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/ID.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/ID.java iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/ID.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/ID.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.apache.iotdb.db.queryengine.execution.schedule.queue;
+package org.apache.iotdb.calc.execution.schedule.queue;
 
 /** A simple interface to indicate the id type. */
 public interface ID {}

…/schedule/queue/IDIndexedAccessible.java …/schedule/queue/IDIndexedAccessible.javaiotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/IDIndexedAccessible.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IDIndexedAccessible.java iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/IDIndexedAccessible.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IDIndexedAccessible.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.apache.iotdb.db.queryengine.execution.schedule.queue;
+package org.apache.iotdb.calc.execution.schedule.queue;
 
 /**
  * A simple interface for id getter and setter.

…schedule/queue/IndexedBlockingQueue.java …schedule/queue/IndexedBlockingQueue.javaiotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/IndexedBlockingQueue.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IndexedBlockingQueue.java iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/IndexedBlockingQueue.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IndexedBlockingQueue.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.apache.iotdb.db.queryengine.execution.schedule.queue;
+package org.apache.iotdb.calc.execution.schedule.queue;
 
 import com.google.common.base.Preconditions;
 
@@ -166,7 +166,7 @@ public final synchronized int size() {
    *
    * @return true if the queue is empty, otherwise false.
    */
-  protected abstract boolean isEmpty();
+  public abstract boolean isEmpty();
 
   /**
    * Get and remove the first element.

…e/queue/IndexedBlockingReserveQueue.java …e/queue/IndexedBlockingReserveQueue.javaiotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/IndexedBlockingReserveQueue.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IndexedBlockingReserveQueue.java iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/schedule/queue/IndexedBlockingReserveQueue.java renamed to iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/execution/schedule/queue/IndexedBlockingReserveQueue.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.apache.iotdb.db.queryengine.execution.schedule.queue;
+package org.apache.iotdb.calc.execution.schedule.queue;
 
 import com.google.common.base.Preconditions;
 

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/AbstractCaseWhenThenColumnTransformer.java

@@ -230,4 +230,15 @@ protected abstract void writeToColumnBuilder(
   protected void checkType() {
     // do nothing
   }
+
+  @Override
+  public void close() {
+    super.close();
+    for (Pair<ColumnTransformer, ColumnTransformer> whenThenColumnTransformer :
+        whenThenTransformers) {
+      whenThenColumnTransformer.left.close();
+      whenThenColumnTransformer.right.close();
+    }
+    elseTransformer.close();
+  }
 }

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/binary/BinaryColumnTransformer.java

@@ -95,4 +95,11 @@ public void clearCache() {
     this.leftTransformer.clearCache();
     this.rightTransformer.clearCache();
   }
+
+  @Override
+  public void close() {
+    super.close();
+    this.leftTransformer.close();
+    this.rightTransformer.close();
+  }
 }

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/MappableUDFColumnTransformer.java

@@ -85,6 +85,10 @@ public ColumnTransformer[] getInputColumnTransformers() {
 
   @Override
   public void close() {
+    super.close();
+    for (ColumnTransformer inputColumnTransformer : inputColumnTransformers) {
+      inputColumnTransformer.close();
+    }
     // finalize executor
     executor.beforeDestroy();
   }

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/multi/MultiColumnTransformer.java

@@ -96,4 +96,12 @@ public void clearCache() {
       columnTransformer.clearCache();
     }
   }
+
+  @Override
+  public void close() {
+    super.close();
+    for (ColumnTransformer columnTransformer : columnTransformerList) {
+      columnTransformer.close();
+    }
+  }
 }

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/ternary/TernaryColumnTransformer.java

@@ -110,4 +110,12 @@ public void clearCache() {
     secondColumnTransformer.clearCache();
     thirdColumnTransformer.clearCache();
   }
+
+  @Override
+  public void close() {
+    super.close();
+    firstColumnTransformer.close();
+    secondColumnTransformer.close();
+    thirdColumnTransformer.close();
+  }
 }

iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/transformation/dag/column/unary/UnaryColumnTransformer.java

@@ -72,4 +72,10 @@ public void clearCache() {
     super.clearCache();
     childColumnTransformer.clearCache();
   }
+
+  @Override
+  public void close() {
+    super.close();
+    childColumnTransformer.close();
+  }
 }