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); }
