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

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

commit 67ca53625e3099a32b0562a214fe6aec6a9993ca
Author: JackieTien97 <[email protected]>
AuthorDate: Wed Nov 17 11:18:14 2021 +0800

    add some comments and delete some useless functions
---
 .../main/java/org/apache/iotdb/db/qp/physical/crud/QueryPlan.java   | 4 ----
 .../java/org/apache/iotdb/db/qp/physical/crud/RawDataQueryPlan.java | 6 ++----
 2 files changed, 2 insertions(+), 8 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/QueryPlan.java 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/QueryPlan.java
index e947144..5163da6 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/QueryPlan.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/QueryPlan.java
@@ -124,10 +124,6 @@ public abstract class QueryPlan extends PhysicalPlan {
     return false;
   }
 
-  public void setPathToIndex(Map<String, Integer> pathToIndex) {
-    this.pathToIndex = pathToIndex;
-  }
-
   public Map<String, Integer> getPathToIndex() {
     return pathToIndex;
   }
diff --git 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/RawDataQueryPlan.java
 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/RawDataQueryPlan.java
index 814a4c7..863a586 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/RawDataQueryPlan.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/qp/physical/crud/RawDataQueryPlan.java
@@ -66,7 +66,6 @@ public class RawDataQueryPlan extends QueryPlan {
     }
     indexedPaths.sort(Comparator.comparing(pair -> pair.left));
 
-    Map<String, Integer> pathNameToReaderIndex = new HashMap<>();
     Set<String> columnForReaderSet = new HashSet<>();
     Set<String> columnForDisplaySet = new HashSet<>();
 
@@ -74,10 +73,10 @@ public class RawDataQueryPlan extends QueryPlan {
       PartialPath originalPath = indexedPath.left;
       Integer originalIndex = indexedPath.right;
 
+      // TODO this method must have some big problem
       String columnForReader = getColumnForReaderFromPath(originalPath, 
originalIndex);
       if (!columnForReaderSet.contains(columnForReader)) {
         addDeduplicatedPaths(originalPath);
-        pathNameToReaderIndex.put(columnForReader, 
pathNameToReaderIndex.size());
         if (this instanceof AggregationPlan) {
           ((AggregationPlan) this)
               
.addDeduplicatedAggregations(getAggregations().get(originalIndex));
@@ -92,8 +91,7 @@ public class RawDataQueryPlan extends QueryPlan {
       }
     }
 
-    // if it is a RawQueryWithoutValueFilter, we also need to group all the 
subSensors of one
-    // vector into one VectorPartialPath
+    // group all the aligned sensors of one device into one AlignedPath
     groupVectorPaths(physicalGenerator);
   }
 

Reply via email to