(iotdb) branch deletion_expr updated: add new expr

[jiangtian]

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

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


The following commit(s) were added to refs/heads/deletion_expr by this push:
     new c3363cb273d add new expr
c3363cb273d is described below

commit c3363cb273d92bf439ad59ddaab8a9c728946c37
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Fri Sep 27 09:37:35 2024 +0800

    add new expr
---
 .../org/apache/iotdb/db/expr/DeletionExprMain.java | 30 +++++++++++++++++++---
 1 file changed, 27 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/expr/DeletionExprMain.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/expr/DeletionExprMain.java
index bda0122e1f7..4fbd42a9ea3 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/expr/DeletionExprMain.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/expr/DeletionExprMain.java
@@ -318,12 +318,36 @@ public class DeletionExprMain {
     parallelExpr(configurer, exprArgs1.length, (i) -> argName1 + ":" + 
exprArgs1[i] +";" + argName2 + ":" + exprArgs2[i], true);
   }
 
+  private static void testTsFileGenInterval() throws ExecutionException, 
InterruptedException {
+    String argName = "tsFileGenerationInterval";
+    long[] exprArgs = new long[]{
+        10_000_000L,
+        20_000_000L,
+        40_000_000L,
+        80_000_000L,
+        160_000_000L,
+    };
+    Configurer configurer = (expr, j) -> {
+      expr.config.generateTsFileInterval = exprArgs[j];
+      expr.config.partialDeletionStep = (long) (expr.config.tsfileRange / (
+          1.0 * expr.config.generateTsFileInterval / 
expr.config.generatePartialDeletionInterval));
+      expr.config.deletionStartTime = 1000 * 
expr.config.generateTsFileInterval;
+      expr.config.rangeQueryStep = expr.config.tsfileRange / 
(expr.config.generateTsFileInterval
+          / expr.config.rangeQueryInterval);
+      expr.config.rangeQueryOffset = -expr.config.rangeQueryRange
+          + expr.config.deletionStartTime / expr.config.generateTsFileInterval
+          * expr.config.tsfileRange;
+    };
+    parallelExpr(configurer, exprArgs.length, (i) -> argName + ":" + 
exprArgs[i], false);
+  }
+
   public static void main(String[] args) throws ExecutionException, 
InterruptedException {
-    maxFileCntThreshold = 30;
+    maxFileCntThreshold = 100;
 
-//    testSizeThreshold();
+    testSizeThreshold();
 //    testQueryInterval();
 //    testSimulationTime();
-    testDeletionRatio();
+//    testDeletionRatio();
+//    testTsFileGenInterval();
   }
 }