Implement absolute time range in search command

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Unit test search with absolute time range

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Rephrase timeRange and timeModifier

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Switch to earliest and latest udf

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Add a convert util

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Verify time correctness during coversion

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Fix quarter parsing bugs

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Fix week snap parsing

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Remove old implementation that translates time modifier to time filter

Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>

Author: yuancu

core/build.gradle

@@ -74,6 +74,7 @@ dependencies {
     testImplementation group: 'org.hamcrest', name: 'hamcrest-library', version: "${hamcrest_version}"
     testImplementation group: 'org.mockito', name: 'mockito-core', version: "${mockito_version}"
     testImplementation group: 'org.mockito', name: 'mockito-junit-jupiter', version: "${mockito_version}"
+    testImplementation group: 'org.opensearch', name: 'opensearch', version: "${opensearch_version}"
 }
 
 spotless {

core/src/main/java/org/opensearch/sql/calcite/CalciteRexNodeVisitor.java

@@ -46,6 +46,7 @@
 import org.opensearch.sql.ast.expression.Cast;
 import org.opensearch.sql.ast.expression.Compare;
 import org.opensearch.sql.ast.expression.EqualTo;
+import org.opensearch.sql.ast.expression.Field;
 import org.opensearch.sql.ast.expression.Function;
 import org.opensearch.sql.ast.expression.In;
 import org.opensearch.sql.ast.expression.Interval;
@@ -67,6 +68,7 @@
 import org.opensearch.sql.ast.expression.subquery.InSubquery;
 import org.opensearch.sql.ast.expression.subquery.ScalarSubquery;
 import org.opensearch.sql.ast.tree.UnresolvedPlan;
+import org.opensearch.sql.calcite.plan.OpenSearchConstants;
 import org.opensearch.sql.calcite.utils.OpenSearchTypeFactory;
 import org.opensearch.sql.calcite.utils.PlanUtils;
 import org.opensearch.sql.common.utils.StringUtils;
@@ -365,6 +367,11 @@ public RexNode visitSpan(Span node, CalcitePlanContext context) {
         context.rexBuilder, BuiltinFunctionName.SPAN, field, value, unitNode);
   }
 
+  private RexNode referenceImplicitTimestampField(CalcitePlanContext context) {
+    return analyze(
+        new Field(new QualifiedName(OpenSearchConstants.IMPLICIT_FIELD_TIMESTAMP)), context);
+  }
+
   private boolean isTimeBased(SpanUnit unit) {
     return !(unit == NONE || unit == UNKNOWN);
   }

core/src/main/java/org/opensearch/sql/calcite/plan/OpenSearchConstants.java

@@ -20,6 +20,8 @@ public interface OpenSearchConstants {
 
   String METADATA_FIELD_ROUTING = "_routing";
 
+  String IMPLICIT_FIELD_TIMESTAMP = "@timestamp";
+
   java.util.Map<String, ExprType> METADATAFIELD_TYPE_MAP =
       Map.of(
           METADATA_FIELD_ID, ExprCoreType.STRING,

core/src/main/java/org/opensearch/sql/expression/function/udf/condition/EarliestFunction.java

@@ -66,6 +66,6 @@ public static Boolean earliest(Object... inputs) {
     ZonedDateTime earliest =
         getRelativeZonedDateTime(
             expression, ZonedDateTime.ofInstant(clock.instant(), clock.getZone()));
-    return earliest.isBefore(candidateDatetime);
+    return !earliest.isAfter(candidateDatetime);
   }
 }

core/src/main/java/org/opensearch/sql/expression/function/udf/condition/LatestFunction.java

@@ -66,6 +66,6 @@ public static Boolean latest(Object... inputs) {
     ZonedDateTime latest =
         getRelativeZonedDateTime(
             expression, ZonedDateTime.ofInstant(clock.instant(), clock.getZone()));
-    return latest.isAfter(candidateDatetime);
+    return !latest.isBefore(candidateDatetime);
   }
 }