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 2022/01/10 11:30:06 UTC

[iotdb] branch AlignedQueryWithValueFilter updated: optimize aggregation query with value filter

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch AlignedQueryWithValueFilter
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/AlignedQueryWithValueFilter by this push:
     new 987442b  optimize aggregation query with value filter
987442b is described below

commit 987442be1983d0487c68cf4e24c209f6055a3b0f
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Mon Jan 10 19:26:50 2022 +0800

    optimize aggregation query with value filter
---
 server/src/main/java/org/apache/iotdb/db/metadata/path/AlignedPath.java | 1 +
 server/src/main/java/org/apache/iotdb/db/metadata/utils/MetaUtils.java  | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/path/AlignedPath.java b/server/src/main/java/org/apache/iotdb/db/metadata/path/AlignedPath.java
index b585559..8aa7b54 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/path/AlignedPath.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/path/AlignedPath.java
@@ -218,6 +218,7 @@ public class AlignedPath extends PartialPath {
     result.fullPath = fullPath;
     result.device = device;
     result.measurementList = new ArrayList<>(measurementList);
+    result.schemaList = new ArrayList<>(schemaList);
     return result;
   }
 
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/utils/MetaUtils.java b/server/src/main/java/org/apache/iotdb/db/metadata/utils/MetaUtils.java
index db9406b..33f6b53 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/utils/MetaUtils.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/utils/MetaUtils.java
@@ -182,7 +182,7 @@ public class MetaUtils {
         List<Integer> indexes = pathToAggrIndexesMap.remove(seriesPath);
         AlignedPath groupPath = temp.get(seriesPath.getFullPath());
         if (groupPath == null) {
-          groupPath = (AlignedPath) seriesPath;
+          groupPath = (AlignedPath) seriesPath.copy();
           temp.put(groupPath.getFullPath(), groupPath);
           alignedPathToAggrIndexesMap
               .computeIfAbsent(groupPath, key -> new ArrayList<>())