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;