From 840324524b8f969b190a99ca169137b2f48eb4d9 Mon Sep 17 00:00:00 2001 From: lancelly <1435078631@qq.com> Date: Sat, 25 Jan 2025 19:14:28 +0800 Subject: [PATCH] fix typo in OperatorGenerator --- .../db/queryengine/plan/planner/TableOperatorGenerator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java index ef66eabb6523..81bb0dbee8d0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/TableOperatorGenerator.java @@ -41,6 +41,7 @@ import org.apache.iotdb.db.queryengine.execution.operator.ExplainAnalyzeOperator; import org.apache.iotdb.db.queryengine.execution.operator.Operator; import org.apache.iotdb.db.queryengine.execution.operator.OperatorContext; +import org.apache.iotdb.db.queryengine.execution.operator.process.AssignUniqueIdOperator; import org.apache.iotdb.db.queryengine.execution.operator.process.CollectOperator; import org.apache.iotdb.db.queryengine.execution.operator.process.EnforceSingleRowOperator; import org.apache.iotdb.db.queryengine.execution.operator.process.FilterAndProjectOperator; @@ -1632,7 +1633,7 @@ public Operator visitAssignUniqueId(AssignUniqueId node, LocalExecutionPlanConte node.getPlanNodeId(), EnforceSingleRowOperator.class.getSimpleName()); - return new EnforceSingleRowOperator(operatorContext, child); + return new AssignUniqueIdOperator(operatorContext, child); } @Override