[iotdb] branch kyy-2022 updated: update

[leirui]

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

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


The following commit(s) were added to refs/heads/kyy-2022 by this push:
     new 6b0a029  update
6b0a029 is described below

commit 6b0a029baed614652fd4ce642a2b53a61550eff6
Author: Lei Rui <1010953...@qq.com>
AuthorDate: Sun Jan 30 01:48:45 2022 +0800

    update
---
 .../macUDF/QueryFullGameExperimentMacUDF.java      | 42 ++++++++++++++++++++++
 .../apache/iotdb/db/integration/m4/MyTestM4.java   |  2 --
 2 files changed, 42 insertions(+), 2 deletions(-)

diff --git 
a/example/session/src/main/java/org/apache/iotdb/macUDF/QueryFullGameExperimentMacUDF.java
 
b/example/session/src/main/java/org/apache/iotdb/macUDF/QueryFullGameExperimentMacUDF.java
new file mode 100644
index 0000000..334e19d
--- /dev/null
+++ 
b/example/session/src/main/java/org/apache/iotdb/macUDF/QueryFullGameExperimentMacUDF.java
@@ -0,0 +1,42 @@
+package org.apache.iotdb.macUDF;
+
+import org.apache.iotdb.rpc.IoTDBConnectionException;
+import org.apache.iotdb.rpc.StatementExecutionException;
+import org.apache.iotdb.session.Session;
+import org.apache.iotdb.session.SessionDataSet;
+import org.apache.iotdb.tsfile.read.common.RowRecord;
+
+import org.apache.thrift.TException;
+
+public class QueryFullGameExperimentMacUDF {
+
+  private static final String queryFormat =
+      "select M4(%1$s,'tqs'='%3$d','tqe'='%4$d','w'='%5$d') from %2$s where 
time>=%3$d and time<%4$d";
+
+  public static Session session;
+
+  public static void main(String[] args)
+      throws IoTDBConnectionException, StatementExecutionException, TException 
{
+    int intervalNum = Integer.parseInt(args[0]);
+    String measurement = "s6";
+    String device = "root.game";
+    session = new Session("127.0.0.1", 6667, "root", "root");
+    session.open(false);
+    SessionDataSet dataSet;
+    long minTime = 0L;
+    long maxTime = 4264605928301L;
+    long interval = (long) Math.ceil((double) (maxTime - minTime) / 
intervalNum);
+    maxTime = minTime + interval * intervalNum;
+    String sql = String.format(queryFormat, measurement, device, minTime, 
maxTime, intervalNum);
+    dataSet = session.executeQueryStatement(sql);
+    while (dataSet.hasNext()) {
+      RowRecord r = dataSet.next();
+    }
+    session.executeNonQueryStatement("clear cache");
+    dataSet = session.executeFinish();
+    String info = dataSet.getFinishResult();
+    System.out.println(info);
+    dataSet.closeOperationHandle();
+    session.close();
+  }
+}
diff --git 
a/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTestM4.java 
b/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTestM4.java
index d2aabb8..79996df 100644
--- a/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTestM4.java
+++ b/server/src/test/java/org/apache/iotdb/db/integration/m4/MyTestM4.java
@@ -78,8 +78,6 @@ public class MyTestM4 {
     try (Connection connection =
             DriverManager.getConnection("jdbc:iotdb://127.0.0.1:6667/", 
"root", "root");
         Statement statement = connection.createStatement()) {
-      statement.execute(
-          "create function M4 as 
\"org.apache.iotdb.db.query.udf.builtin.UDTFM4MAC\"");
 
       long tqs = 0L;
       long tqe = 100L;