[iotdb] branch IOTDB-3945 created (now 6dc3cb7386)

[ja...@apache.org]

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

jackietien pushed a change to branch IOTDB-3945
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 6dc3cb7386 Support TTL in Mpp

This branch includes the following new commits:

     new 6dc3cb7386 Support TTL in Mpp

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[iotdb] 01/01: Support TTL in Mpp

[ja...@apache.org]

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

jackietien pushed a commit to branch IOTDB-3945
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 6dc3cb7386a6b1d461aef1ff99e0c992857217e6
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Jul 26 17:29:00 2022 +0800

    Support TTL in Mpp
---
 .../iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
index 254693e7b9..af6b72e47a 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/SeriesScanUtil.java
@@ -79,8 +79,8 @@ public class SeriesScanUtil {
    *
    * valueFilter is pushed down to non-overlapped page only
    */
-  private final Filter timeFilter;
-  private final Filter valueFilter;
+  private Filter timeFilter;
+  private Filter valueFilter;
 
   private QueryDataSource dataSource;
 
@@ -161,6 +161,10 @@ public class SeriesScanUtil {
   public void initQueryDataSource(QueryDataSource dataSource) {
     QueryUtils.fillOrderIndexes(dataSource, seriesPath.getDevice(), orderUtils.getAscending());
     this.dataSource = dataSource;
+    this.timeFilter = dataSource.updateFilterUsingTTL(timeFilter);
+    if (this.valueFilter != null) {
+      this.valueFilter = dataSource.updateFilterUsingTTL(valueFilter);
+    }
     orderUtils.setCurSeqFileIndex(dataSource);
   }