feat: add filters for create/update time

Author: bevzzz

src/it/java/io/weaviate/integration/SearchITest.java

@@ -1,6 +1,7 @@
 package io.weaviate.integration;
 
 import java.io.IOException;
+import java.time.OffsetDateTime;
 import java.util.Collections;
 import java.util.Comparator;
 import java.util.HashMap;
@@ -700,4 +701,26 @@ public void test_filterIsNull() throws IOException {
         .hasSize(1).first().actual();
     Assertions.assertThat(isNull_1).isNotEqualTo(isNotNull_1);
   }
+
+  @Test
+  public void test_filterCreateUpdateTime() throws IOException {
+    // Arrange
+    var now = OffsetDateTime.now().minusHours(1);
+    var nsCounter = ns("Counter");
+
+    var counter = client.collections.create(nsCounter,
+        c -> c
+            .invertedIndex(idx -> idx.indexTimestamps(true))
+            .properties(Property.integer("count")));
+
+    counter.data.insert(Map.of("count", 0));
+
+    // Act
+    var beforeNow = counter.query.fetchObjects(q -> q.filters(Filter.createdAt().lt(now)));
+    var afterNow = counter.query.fetchObjects(q -> q.filters(Filter.createdAt().gt(now)));
+
+    // Assert
+    Assertions.assertThat(beforeNow.objects()).isEmpty();
+    Assertions.assertThat(afterNow.objects()).hasSize(1);
+  }
 }

src/main/java/io/weaviate/client6/v1/api/collections/query/BaseQueryOptions.java

@@ -26,6 +26,10 @@ public record BaseQueryOptions(
     List<Metadata> returnMetadata,
     List<String> includeVectors) {
 
+  static final String ID_PROPERTY = "_id";
+  static final String CREATION_TIME_PROPERTY = "_creationTimeUnix";
+  static final String LAST_UPDATE_TIME_PROPERTY = "_lastUpdateTimeUnix";
+
   private <T extends Object> BaseQueryOptions(Builder<? extends Builder<?, T>, T> builder) {
     this(
         builder.limit,

src/main/java/io/weaviate/client6/v1/api/collections/query/FetchObjectById.java

@@ -19,8 +19,6 @@ public record FetchObjectById(
     List<Metadata> returnMetadata,
     List<String> includeVectors) implements QueryOperator {
 
-  static final String ID_PROPERTY = "_id";
-
   public static FetchObjectById of(String uuid) {
     return of(uuid, ObjectBuilder.identity());
   }

src/main/java/io/weaviate/client6/v1/api/collections/query/Filter.java

@@ -18,10 +18,10 @@ private enum Operator {
     // Comparison operators
     EQUAL("Equal", WeaviateProtoBase.Filters.Operator.OPERATOR_EQUAL),
     NOT_EQUAL("NotEqual", WeaviateProtoBase.Filters.Operator.OPERATOR_NOT_EQUAL),
-    LESS_THAN("LessThen", WeaviateProtoBase.Filters.Operator.OPERATOR_LESS_THAN),
+    LESS_THAN("LessThan", WeaviateProtoBase.Filters.Operator.OPERATOR_LESS_THAN),
     LESS_THAN_EQUAL("LessThenEqual", WeaviateProtoBase.Filters.Operator.OPERATOR_LESS_THAN_EQUAL),
-    GREATER_THAN("GreaterThen", WeaviateProtoBase.Filters.Operator.OPERATOR_GREATER_THAN),
-    GREATER_THAN_EQUAL("GreaterThenEqual", WeaviateProtoBase.Filters.Operator.OPERATOR_GREATER_THAN_EQUAL),
+    GREATER_THAN("GreaterThan", WeaviateProtoBase.Filters.Operator.OPERATOR_GREATER_THAN),
+    GREATER_THAN_EQUAL("GreaterThanEqual", WeaviateProtoBase.Filters.Operator.OPERATOR_GREATER_THAN_EQUAL),
     IS_NULL("IsNull", WeaviateProtoBase.Filters.Operator.OPERATOR_IS_NULL),
     LIKE("Like", WeaviateProtoBase.Filters.Operator.OPERATOR_LIKE),
     CONTAINS_ANY("ContainsAny", WeaviateProtoBase.Filters.Operator.OPERATOR_CONTAINS_ANY),
@@ -111,7 +111,17 @@ public Filter not() {
 
   /** Filter by object UUID. */
   public static FilterBuilder uuid() {
-    return property(FetchObjectById.ID_PROPERTY);
+    return property(BaseQueryOptions.ID_PROPERTY);
+  }
+
+  /** Filter by object creation time. */
+  public static DateProperty createdAt() {
+    return new DateProperty(BaseQueryOptions.CREATION_TIME_PROPERTY);
+  }
+
+  /** Filter by object last update time. */
+  public static DateProperty lastUpdatedAt() {
+    return new DateProperty(BaseQueryOptions.LAST_UPDATE_TIME_PROPERTY);
   }
 
   /** Filter by object property. */
@@ -635,6 +645,44 @@ public String toString() {
     }
   }
 
+  public static class DateProperty extends PathOperand {
+    private DateProperty(String propertyName) {
+      super(propertyName);
+    }
+
+    public Filter eq(OffsetDateTime value) {
+      return new Filter(Operator.EQUAL, this, new DateOperand(value));
+    }
+
+    public Filter ne(OffsetDateTime value) {
+      return new Filter(Operator.NOT_EQUAL, this, new DateOperand(value));
+    }
+
+    public Filter gt(OffsetDateTime value) {
+      return new Filter(Operator.GREATER_THAN, this, new DateOperand(value));
+    }
+
+    public Filter gte(OffsetDateTime value) {
+      return new Filter(Operator.GREATER_THAN_EQUAL, this, new DateOperand(value));
+    }
+
+    public Filter lt(OffsetDateTime value) {
+      return new Filter(Operator.LESS_THAN, this, new DateOperand(value));
+    }
+
+    public Filter lte(OffsetDateTime value) {
+      return new Filter(Operator.LESS_THAN_EQUAL, this, new DateOperand(value));
+    }
+
+    public Filter containsAny(OffsetDateTime... values) {
+      return new Filter(Operator.CONTAINS_ANY, this, new DateArrayOperand(values));
+    }
+
+    public Filter containsNone(OffsetDateTime... values) {
+      return new Filter(Operator.CONTAINS_NONE, this, new DateArrayOperand(values));
+    }
+  }
+
   private static class TextOperand implements FilterOperand {
     private final String value;
 

src/main/java/io/weaviate/client6/v1/api/collections/query/SortBy.java

@@ -26,7 +26,7 @@ public static SortBy property(String property) {
    * @see #desc() to sort in descending order.
    */
   public static SortBy uuid() {
-    return property(FetchObjectById.ID_PROPERTY);
+    return property(BaseQueryOptions.ID_PROPERTY);
   }
 
   /**