[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);
   }