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

leirui pushed a commit to branch research/M4-visualization
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/research/M4-visualization by 
this push:
     new 27d43f1a712 update readme
27d43f1a712 is described below

commit 27d43f1a71271d3d7a424f0a7718a7015e3e1e75
Author: Lei Rui <[email protected]>
AuthorDate: Thu Jul 20 00:38:47 2023 +0800

    update readme
---
 .../db/query/dataset/groupby/LocalGroupByExecutor4CPV.java    | 11 +----------
 .../test/java/org/apache/iotdb/db/integration/m4/MyTest1.java |  7 ++++++-
 2 files changed, 7 insertions(+), 11 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java
 
b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java
index c4dec2679a4..031d08c33ab 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor4CPV.java
@@ -56,13 +56,7 @@ import java.util.ListIterator;
 import java.util.Map;
 import java.util.Set;
 
-/**
- * Sql format: SELECT min_time(s0), max_time(s0), first_value(s0), 
last_value(s0), min_value(s0),
- * max_value(s0) ROM root.xx group by ([tqs,tqe),IntervalLength). 
Requirements: (1) Don't change the
- * sequence of the above six aggregates (2) Make sure (tqe-tqs) is divisible 
by IntervalLength. (3)
- * Assume each chunk has only one page.
- */
-// This is the CPVGroupByExecutor in M4-LSM paper.
+// This is the MFGroupByExecutor in M4-LSM paper.
 public class LocalGroupByExecutor4CPV implements GroupByExecutor {
 
   private static final Logger M4_CHUNK_METADATA = 
LoggerFactory.getLogger("M4_CHUNK_METADATA");
@@ -82,8 +76,6 @@ public class LocalGroupByExecutor4CPV implements 
GroupByExecutor {
 
   private TSDataType tsDataType;
 
-  //  private PriorityMergeReader mergeReader;
-
   public LocalGroupByExecutor4CPV(
       PartialPath path,
       Set<String> allSensors,
@@ -96,7 +88,6 @@ public class LocalGroupByExecutor4CPV implements 
GroupByExecutor {
     //    long start = System.nanoTime();
 
     this.tsDataType = dataType;
-    //    this.mergeReader = new PriorityMergeReader();
 
     // get all data sources
     QueryDataSource queryDataSource =
diff --git 
a/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest1.java 
b/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest1.java
index cfbe5c63e81..7230a4f88a3 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest1.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTest1.java
@@ -108,11 +108,16 @@ public class MyTest1 {
     try (Connection connection =
             DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", 
"root", "root");
         Statement statement = connection.createStatement()) {
+      /*
+       * Sql format: SELECT min_time(s0), max_time(s0), first_value(s0), 
last_value(s0), min_value(s0),
+       * max_value(s0) ROM root.xx group by ([tqs,tqe),IntervalLength). 
Requirements: (1) Don't change the
+       * sequence of the above six aggregates (2) Make sure (tqe-tqs) is 
divisible by IntervalLength. (3)
+       * Assume each chunk has only one page.
+       */
       boolean hasResultSet =
           statement.execute(
               "SELECT min_time(s0), max_time(s0), first_value(s0), 
last_value(s0), min_value(s0), max_value(s0)"
                   + " FROM root.vehicle.d0 group by ([0,100),25ms)");
-
       Assert.assertTrue(hasResultSet);
       try (ResultSet resultSet = statement.getResultSet()) {
         int i = 0;

Reply via email to