implement

Author: Wei-hao-Li

java/tsfile/src/main/java/org/apache/tsfile/read/filter/basic/Filter.java

@@ -26,6 +26,7 @@
 import org.apache.tsfile.read.filter.factory.TimeFilterApi;
 import org.apache.tsfile.read.filter.factory.ValueFilterApi;
 import org.apache.tsfile.read.filter.operator.And;
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators;
 import org.apache.tsfile.read.filter.operator.GroupByFilter;
 import org.apache.tsfile.read.filter.operator.GroupByMonthFilter;
 import org.apache.tsfile.read.filter.operator.Not;
@@ -245,6 +246,18 @@ public static Filter deserialize(ByteBuffer buffer) {
         return new Or(buffer);
       case NOT:
         return new Not(buffer);
+      case EXTRACT_TIME_EQ:
+        return new ExtractTimeFilterOperators.ExtractTimeEq(buffer);
+      case EXTRACT_TIME_NEQ:
+        return new ExtractTimeFilterOperators.ExtractTimeNotEq(buffer);
+      case EXTRACT_TIME_GT:
+        return new ExtractTimeFilterOperators.ExtractTimeGt(buffer);
+      case EXTRACT_TIME_GTEQ:
+        return new ExtractTimeFilterOperators.ExtractTimeGtEq(buffer);
+      case EXTRACT_TIME_LT:
+        return new ExtractTimeFilterOperators.ExtractTimeLt(buffer);
+      case EXTRACT_TIME_LTEQ:
+        return new ExtractTimeFilterOperators.ExtractTimeLtEq(buffer);
       default:
         throw new UnsupportedOperationException("Unsupported operator type:" + type);
     }

java/tsfile/src/main/java/org/apache/tsfile/read/filter/basic/OperatorType.java

@@ -65,7 +65,15 @@ public enum OperatorType {
 
   // is null
   VALUE_IS_NULL("IS NULL"),
-  VALUE_IS_NOT_NULL("IS NOT NULL");
+  VALUE_IS_NOT_NULL("IS NOT NULL"),
+
+  // extract comparison
+  EXTRACT_TIME_EQ("="),
+  EXTRACT_TIME_NEQ("!="),
+  EXTRACT_TIME_GT(">"),
+  EXTRACT_TIME_GTEQ(">="),
+  EXTRACT_TIME_LT("<"),
+  EXTRACT_TIME_LTEQ("<=");
 
   private final String symbol;
 

java/tsfile/src/main/java/org/apache/tsfile/read/filter/factory/TimeFilterApi.java

@@ -19,6 +19,13 @@
 
 package org.apache.tsfile.read.filter.factory;
 
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators.ExtractTimeEq;
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators.ExtractTimeGt;
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators.ExtractTimeGtEq;
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators.ExtractTimeLt;
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators.ExtractTimeLtEq;
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators.ExtractTimeNotEq;
+import org.apache.tsfile.read.filter.operator.ExtractTimeFilterOperators.Field;
 import org.apache.tsfile.read.filter.operator.GroupByFilter;
 import org.apache.tsfile.read.filter.operator.GroupByMonthFilter;
 import org.apache.tsfile.read.filter.operator.TimeFilterOperators.TimeBetweenAnd;
@@ -33,6 +40,7 @@
 import org.apache.tsfile.read.filter.operator.TimeFilterOperators.TimeNotIn;
 import org.apache.tsfile.utils.TimeDuration;
 
+import java.time.ZoneId;
 import java.util.Set;
 import java.util.TimeZone;
 import java.util.concurrent.TimeUnit;
@@ -98,4 +106,34 @@ public static GroupByMonthFilter groupByMonth(
     return new GroupByMonthFilter(
         startTime, endTime, interval, slidingStep, timeZone, currPrecision);
   }
+
+  public static ExtractTimeGt extractTimeGt(
+      long value, Field field, ZoneId zoneId, TimeUnit currPrecision) {
+    return new ExtractTimeGt(value, field, zoneId, currPrecision);
+  }
+
+  public static ExtractTimeGtEq extractTimeGtEq(
+      long value, Field field, ZoneId zoneId, TimeUnit currPrecision) {
+    return new ExtractTimeGtEq(value, field, zoneId, currPrecision);
+  }
+
+  public static ExtractTimeLt extractTimeLt(
+      long value, Field field, ZoneId zoneId, TimeUnit currPrecision) {
+    return new ExtractTimeLt(value, field, zoneId, currPrecision);
+  }
+
+  public static ExtractTimeLtEq extractTimeLtEq(
+      long value, Field field, ZoneId zoneId, TimeUnit currPrecision) {
+    return new ExtractTimeLtEq(value, field, zoneId, currPrecision);
+  }
+
+  public static ExtractTimeEq extractTimeEq(
+      long value, Field field, ZoneId zoneId, TimeUnit currPrecision) {
+    return new ExtractTimeEq(value, field, zoneId, currPrecision);
+  }
+
+  public static ExtractTimeNotEq extractTimeNotEq(
+      long value, Field field, ZoneId zoneId, TimeUnit currPrecision) {
+    return new ExtractTimeNotEq(value, field, zoneId, currPrecision);
+  }
 }