fix IT

Signed-off-by: Lantao Jin <ltjin@amazon.com>

Author: LantaoJin

core/src/main/java/org/opensearch/sql/expression/function/udf/datetime/FromUnixTimeFunction.java

@@ -10,6 +10,7 @@
 import static org.opensearch.sql.expression.datetime.DateTimeFunctions.exprFromUnixTime;
 import static org.opensearch.sql.expression.datetime.DateTimeFunctions.exprFromUnixTimeFormat;
 
+import java.math.BigDecimal;
 import java.util.List;
 import org.apache.calcite.adapter.enumerable.NotNullImplementor;
 import org.apache.calcite.adapter.enumerable.NullPolicy;
@@ -60,6 +61,10 @@ public static String fromUnixTime(double unixTime) {
       return (String) exprFromUnixTime(new ExprDoubleValue(unixTime)).valueForCalcite();
     }
 
+    public static String fromUnixTime(BigDecimal unixTime) {
+      return (String) exprFromUnixTime(new ExprDoubleValue(unixTime)).valueForCalcite();
+    }
+
     public static String fromUnixTime(double unixTime, String format) {
       return (String)
           exprFromUnixTimeFormat(new ExprDoubleValue(unixTime), new ExprStringValue(format))

core/src/main/java/org/opensearch/sql/expression/function/udf/datetime/SecToTimeFunction.java

@@ -16,6 +16,7 @@
 import org.apache.calcite.linq4j.tree.Expressions;
 import org.apache.calcite.rex.RexCall;
 import org.apache.calcite.sql.type.SqlReturnTypeInference;
+import org.opensearch.sql.calcite.utils.MathUtils;
 import org.opensearch.sql.calcite.utils.PPLReturnTypes;
 import org.opensearch.sql.data.model.ExprValue;
 import org.opensearch.sql.data.model.ExprValueUtils;
@@ -55,7 +56,7 @@ public Expression implement(
     public static String secToTime(Number seconds) {
       ExprValue returnTimeValue;
       ExprValue transferredValue = ExprValueUtils.fromObjectValue(seconds);
-      if (seconds instanceof Long || seconds instanceof Integer) {
+      if (MathUtils.isIntegral(seconds)) {
         returnTimeValue = exprSecToTime(transferredValue);
       } else {
         returnTimeValue = exprSecToTimeWithNanos(transferredValue);

integ-test/src/test/java/org/opensearch/sql/calcite/standalone/CalcitePPLExplainPushdownIT.java

@@ -28,7 +28,7 @@ public void testExplainCommand() {
             + "    \"physical\": \"CalciteEnumerableIndexScan(table=[[OpenSearch, test]],"
             + " PushDownContext=[[PROJECT->[name, age], FILTER->=($1, 20)],"
             + " OpenSearchRequestBuilder(sourceBuilder={\\\"from\\\":0,\\\"timeout\\\":\\\"1m\\\",\\\"query\\\":{\\\"term\\\":{\\\"age\\\":{\\\"value\\\":20,\\\"boost\\\":1.0}}},\\\"_source\\\":{\\\"includes\\\":[\\\"name\\\",\\\"age\\\"],\\\"excludes\\\":[]},\\\"sort\\\":[{\\\"_doc\\\":{\\\"order\\\":\\\"asc\\\"}}]},"
-            + " requestedTotalSize=200, pageSize=null, startFrom=0)])\\n"
+            + " requestedTotalSize=2000, pageSize=null, startFrom=0)])\\n"
             + "\"\n"
             + "  }\n"
             + "}",
@@ -52,7 +52,7 @@ public void testExplainCommandCost() {
             + "    \"physical\": \"CalciteEnumerableIndexScan(table=[[OpenSearch, test]],"
             + " PushDownContext=[[PROJECT->[name, age], FILTER->=($1, 20)],"
             + " OpenSearchRequestBuilder(sourceBuilder={\\\"from\\\":0,\\\"timeout\\\":\\\"1m\\\",\\\"query\\\":{\\\"term\\\":{\\\"age\\\":{\\\"value\\\":20,\\\"boost\\\":1.0}}},\\\"_source\\\":{\\\"includes\\\":[\\\"name\\\",\\\"age\\\"],\\\"excludes\\\":[]},\\\"sort\\\":[{\\\"_doc\\\":{\\\"order\\\":\\\"asc\\\"}}]},"
-            + " requestedTotalSize=200, pageSize=null, startFrom=0)]): rowcount = 1215.0,"
+            + " requestedTotalSize=2000, pageSize=null, startFrom=0)]): rowcount = 1215.0,"
             + " cumulative cost = {1215.0 rows, 1216.0 cpu, 0.0 io}, id = *\\n"
             + "\"\n"
             + "  }\n"