You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/02/01 05:11:03 UTC
[iotdb] 02/02: Optimize group by level
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch geely_car
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b09bdb20c17e8486531092ff95ae7242c0b42fe1
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Wed Feb 1 13:10:53 2023 +0800
Optimize group by level
---
.../iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
index f06081d21b..5060d26240 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
@@ -966,24 +966,24 @@ public class SourceRewriter extends SimplePlanNodeRewriter<DistributionPlanConte
// AggregationDescriptor
List<CrossSeriesAggregationDescriptor> descriptorList = new ArrayList<>();
Map<String, Expression> columnNameToExpression = context.getColumnNameToExpression();
- Set<Expression> childrenExpressionMap = new HashSet<>();
+ Set<Expression> childrenExpressionSet = new HashSet<>();
for (String childColumn : childrenOutputColumns) {
Expression childExpression =
columnNameToExpression.get(
childColumn.substring(childColumn.indexOf("(") + 1, childColumn.lastIndexOf(")")));
- childrenExpressionMap.add(childExpression);
+ childrenExpressionSet.add(childExpression);
}
for (CrossSeriesAggregationDescriptor originalDescriptor :
handle.getGroupByLevelDescriptors()) {
Set<Expression> descriptorExpressions = new HashSet<>();
- if (childrenExpressionMap.contains(originalDescriptor.getOutputExpression())) {
+ if (childrenExpressionSet.contains(originalDescriptor.getOutputExpression())) {
descriptorExpressions.add(originalDescriptor.getOutputExpression());
}
for (Expression exp : originalDescriptor.getInputExpressions()) {
- if (childrenExpressionMap.contains(exp)) {
+ if (childrenExpressionSet.contains(exp)) {
descriptorExpressions.add(exp);
}
}