This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a commit to branch udtf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/udtf by this push:
new 25ed53021a4 remove log
25ed53021a4 is described below
commit 25ed53021a42ad00d469790afe91a949ce81b686
Author: Chen YZ <[email protected]>
AuthorDate: Wed Mar 12 00:43:21 2025 +0800
remove log
---
.../execution/operator/process/SortOperator.java | 23 --------------------
.../process/function/PartitionRecognizer.java | 25 ----------------------
.../process/function/TableFunctionOperator.java | 15 +------------
3 files changed, 1 insertion(+), 62 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/SortOperator.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/SortOperator.java
index 4e603347595..31029a30da6 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/SortOperator.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/SortOperator.java
@@ -26,7 +26,6 @@ import
org.apache.iotdb.db.queryengine.execution.operator.OperatorContext;
import org.apache.iotdb.db.utils.datastructure.SortKey;
import org.apache.iotdb.db.utils.sort.DiskSpiller;
-import org.apache.tsfile.block.column.Column;
import org.apache.tsfile.enums.TSDataType;
import org.apache.tsfile.read.common.block.TsBlock;
import org.apache.tsfile.read.common.block.TsBlockBuilder;
@@ -55,17 +54,6 @@ public abstract class SortOperator extends
AbstractSortOperator {
buildResult();
TsBlock res = buildFinalResult(tsBlockBuilder);
tsBlockBuilder.reset();
- System.out.println("====== sort result ======= ");
- for (int i = 0; i < res.getPositionCount(); i++) {
- for (Column column : res.getValueColumns()) {
- if (column.isNull(i)) {
- System.out.print("null, ");
- } else {
- System.out.print(column.getObject(i) + ", ");
- }
- }
- System.out.println();
- }
return res;
}
long startTime = System.nanoTime();
@@ -74,17 +62,6 @@ public abstract class SortOperator extends
AbstractSortOperator {
if (tsBlock == null) {
return null;
}
- System.out.println("receive new tsBlock: " + tsBlock);
- for (int i = 0; i < tsBlock.getPositionCount(); i++) {
- for (Column column : tsBlock.getValueColumns()) {
- if (column.isNull(i)) {
- System.out.print("null, ");
- } else {
- System.out.print(column.getObject(i) + ", ");
- }
- }
- System.out.println();
- }
dataSize += tsBlock.getSizeInBytes();
cacheTsBlock(tsBlock);
} catch (IoTDBException e) {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/PartitionRecognizer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/PartitionRecognizer.java
index e76bfb4bfdd..19424f8862e 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/PartitionRecognizer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/PartitionRecognizer.java
@@ -25,7 +25,6 @@ import
org.apache.iotdb.db.queryengine.execution.operator.process.function.parti
import org.apache.iotdb.db.utils.datastructure.SortKey;
import org.apache.iotdb.udf.api.type.Type;
-import org.apache.tsfile.block.column.Column;
import org.apache.tsfile.enums.TSDataType;
import org.apache.tsfile.read.common.block.TsBlock;
@@ -76,21 +75,6 @@ public class PartitionRecognizer {
"The partition handler is finished, cannot add more data.");
}
currentTsBlock = tsBlock;
- System.out.println("====== PartitionRecognizer add tsblock ======= ");
- if (tsBlock == null) {
- System.out.println("NULL TsBlock");
- } else {
- for (int i = 0; i < tsBlock.getPositionCount(); i++) {
- for (Column column : tsBlock.getValueColumns()) {
- if (column.isNull(i)) {
- System.out.print("null, ");
- } else {
- System.out.print(column.getObject(i) + ", ");
- }
- }
- System.out.println();
- }
- }
}
/** Marks the handler as finished. */
@@ -123,7 +107,6 @@ public class PartitionRecognizer {
currentIndex = 0;
currentTsBlock = null;
}
- System.out.println("====== PartitionRecognizer update state: " +
state.getStateType());
}
private PartitionState handleInitState() {
@@ -177,18 +160,10 @@ public class PartitionRecognizer {
while (compareKey.rowIndex < currentTsBlock.getPositionCount()) {
if (partitionComparator.compare(partitionKey, compareKey) != 0) {
partitionKey = compareKey;
- System.out.println(
- Thread.currentThread().getId()
- + " ====== PartitionRecognizer find next different row index
in loop: "
- + compareKey.rowIndex);
return compareKey.rowIndex;
}
compareKey.rowIndex++;
}
- System.out.println(
- Thread.currentThread().getId()
- + " ====== PartitionRecognizer find next different row index out
of loop: "
- + compareKey.rowIndex);
return compareKey.rowIndex;
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/TableFunctionOperator.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/TableFunctionOperator.java
index bab9bfb56c4..b37725a7a39 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/TableFunctionOperator.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/TableFunctionOperator.java
@@ -215,20 +215,7 @@ public class TableFunctionOperator implements
ProcessOperator {
}
}
}
- TsBlock res =
- blockBuilder.build(new RunLengthEncodedColumn(TIME_COLUMN_TEMPLATE,
positionCount));
- System.out.println("====== tvf result ======= ");
- for (int i = 0; i < res.getPositionCount(); i++) {
- for (Column column : res.getValueColumns()) {
- if (column.isNull(i)) {
- System.out.print("null, ");
- } else {
- System.out.print(column.getObject(i) + ", ");
- }
- }
- System.out.println();
- }
- return res;
+ return blockBuilder.build(new RunLengthEncodedColumn(TIME_COLUMN_TEMPLATE,
positionCount));
}
private void consumeCurrentPartitionState() {
