add IT

Signed-off-by: xinyual <xinyual@amazon.com>

Author: xinyual

integ-test/src/test/java/org/opensearch/sql/calcite/remote/CalcitePPLExplainIT.java

@@ -10,6 +10,7 @@
 import java.io.IOException;
 import org.junit.jupiter.api.Test;
 import org.opensearch.client.Request;
+import org.opensearch.sql.legacy.TestsConstants;
 import org.opensearch.sql.ppl.PPLIntegTestCase;
 
 public class CalcitePPLExplainIT extends PPLIntegTestCase {
@@ -30,6 +31,7 @@ public void init() throws Exception {
     Request request3 = new Request("PUT", "/test1/_doc/1?refresh=true");
     request3.setJsonEntity("{\"name\": \"HELLO\", \"alias\": \"Hello\"}");
     client().performRequest(request3);
+    loadIndex(Index.BANK);
   }
 
   @Test
@@ -53,6 +55,23 @@ public void testExplainCommandExtended() throws IOException {
                 + " org.apache.calcite.DataContext root)"));
   }
 
+  @Test
+  public void testFilterPushdown() throws IOException {
+    var result =
+        explainQueryToString(
+            String.format(
+                "source=%s | where birthdate < '2017-11-20 00:00:00'",
+                TestsConstants.TEST_INDEX_BANK));
+    String expected =
+        isPushdownEnabled()
+            ? loadFromFile(
+                "expectedOutput/calcite/explain_filter_compare_string_timestamp_w_pushdown.json")
+            : loadFromFile(
+                "expectedOutput/calcite/explain_filter_compare_string_timestamp_wo_pushdown.json");
+
+    assertJsonEquals(expected, result);
+  }
+
   @Test
   public void testExplainCommandCost() throws IOException {
     var result = executeWithReplace("explain cost source=test | where age = 20 | fields name, age");

integ-test/src/test/resources/expectedOutput/calcite/explain_filter_compare_string_timestamp_w_pushdown.json

@@ -0,0 +1,6 @@
+{
+  "calcite" : {
+    "logical" : "LogicalProject(account_number=[$0], firstname=[$1], address=[$2], birthdate=[$3], gender=[$4], city=[$5], lastname=[$6], balance=[$7], employer=[$8], state=[$9], age=[$10], email=[$11], male=[$12])\n  LogicalFilter(condition=[<($3, TIMESTAMP('2017-11-20 00:00:00':VARCHAR))])\n    CalciteLogicalIndexScan(table=[[OpenSearch, opensearch-sql_test_index_bank]])\n",
+    "physical" : "CalciteEnumerableIndexScan(table=[[OpenSearch, opensearch-sql_test_index_bank]], PushDownContext=[[PROJECT->[account_number, firstname, address, birthdate, gender, city, lastname, balance, employer, state, age, email, male], FILTER-><($3, '2017-11-20 00:00:00')], OpenSearchRequestBuilder(sourceBuilder={\"from\":0,\"timeout\":\"1m\",\"query\":{\"range\":{\"birthdate\":{\"from\":null,\"to\":\"2017-11-20T00:00:00.000Z\",\"include_lower\":true,\"include_upper\":false,\"boost\":1.0}}},\"_source\":{\"includes\":[\"account_number\",\"firstname\",\"address\",\"birthdate\",\"gender\",\"city\",\"lastname\",\"balance\",\"employer\",\"state\",\"age\",\"email\",\"male\"],\"excludes\":[]},\"sort\":[{\"_doc\":{\"order\":\"asc\"}}]}, requestedTotalSize=2147483647, pageSize=null, startFrom=0)])\n"
+  }
+}

integ-test/src/test/resources/expectedOutput/calcite/explain_filter_compare_string_timestamp_wo_pushdown.json

@@ -0,0 +1,6 @@
+{
+  "calcite": {
+    "logical": "LogicalProject(account_number=[$0], firstname=[$1], address=[$2], birthdate=[$3], gender=[$4], city=[$5], lastname=[$6], balance=[$7], employer=[$8], state=[$9], age=[$10], email=[$11], male=[$12])\n  LogicalFilter(condition=[<($3, TIMESTAMP('2017-11-20 00:00:00':VARCHAR))])\n    CalciteLogicalIndexScan(table=[[OpenSearch, opensearch-sql_test_index_bank]])\n",
+    "physical": "EnumerableCalc(expr#0..18=[{inputs}], expr#19=['2017-11-20 00:00:00':EXPR_TIMESTAMP VARCHAR], expr#20=[<($t3, $t19)], proj#0..12=[{exprs}], $condition=[$t20])\n  CalciteEnumerableIndexScan(table=[[OpenSearch, opensearch-sql_test_index_bank]])\n"
+  }
+}