Switch sql dialect to opensearch spark sql dialect (1772/2018)

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

Author: yuancu

api/src/test/java/org/opensearch/sql/api/transpiler/UnifiedQueryTranspilerTest.java

@@ -12,7 +12,7 @@
 import org.junit.Before;
 import org.junit.Test;
 import org.opensearch.sql.api.UnifiedQueryTestBase;
-import org.opensearch.sql.ppl.calcite.OpenSearchSparkSqlDialect;
+import org.opensearch.sql.calcite.validate.OpenSearchSparkSqlDialect;
 
 public class UnifiedQueryTranspilerTest extends UnifiedQueryTestBase {
 

…l/calcite/OpenSearchSparkSqlDialect.java …/validate/OpenSearchSparkSqlDialect.javappl/src/main/java/org/opensearch/sql/ppl/calcite/OpenSearchSparkSqlDialect.java renamed to core/src/main/java/org/opensearch/sql/calcite/validate/OpenSearchSparkSqlDialect.java ppl/src/main/java/org/opensearch/sql/ppl/calcite/OpenSearchSparkSqlDialect.java renamed to core/src/main/java/org/opensearch/sql/calcite/validate/OpenSearchSparkSqlDialect.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package org.opensearch.sql.ppl.calcite;
+package org.opensearch.sql.calcite.validate;
 
 import com.google.common.collect.ImmutableMap;
 import java.util.Map;

core/src/main/java/org/opensearch/sql/executor/QueryService.java

@@ -36,7 +36,6 @@
 import org.apache.calcite.sql.SqlCall;
 import org.apache.calcite.sql.SqlIdentifier;
 import org.apache.calcite.sql.SqlNode;
-import org.apache.calcite.sql.dialect.SparkSqlDialect;
 import org.apache.calcite.sql.fun.SqlCountAggFunction;
 import org.apache.calcite.sql.fun.SqlStdOperatorTable;
 import org.apache.calcite.sql.parser.SqlParser;
@@ -56,6 +55,7 @@
 import org.opensearch.sql.calcite.SysLimit;
 import org.opensearch.sql.calcite.plan.LogicalSystemLimit;
 import org.opensearch.sql.calcite.plan.LogicalSystemLimit.SystemLimitType;
+import org.opensearch.sql.calcite.validate.OpenSearchSparkSqlDialect;
 import org.opensearch.sql.calcite.validate.PplConvertletTable;
 import org.opensearch.sql.calcite.validate.PplRelToSqlNodeConverter;
 import org.opensearch.sql.calcite.validate.PplRelToSqlRelShuttle;
@@ -310,7 +310,7 @@ private RelNode validate(RelNode relNode, CalcitePlanContext context) {
     RelNode sqlRelNode = relNode.accept(new PplRelToSqlRelShuttle(context.rexBuilder, true));
 
     // Convert RelNode to SqlNode for validation
-    RelToSqlConverter rel2sql = new PplRelToSqlNodeConverter(SparkSqlDialect.DEFAULT);
+    RelToSqlConverter rel2sql = new PplRelToSqlNodeConverter(OpenSearchSparkSqlDialect.DEFAULT);
     SqlImplementor.Result result = rel2sql.visitRoot(sqlRelNode);
     SqlNode root = result.asStatement();
 

ppl/src/test/java/org/opensearch/sql/ppl/calcite/CalcitePPLAbstractTest.java

@@ -45,6 +45,7 @@
 import org.opensearch.sql.calcite.CalcitePlanContext;
 import org.opensearch.sql.calcite.CalciteRelNodeVisitor;
 import org.opensearch.sql.calcite.SysLimit;
+import org.opensearch.sql.calcite.validate.OpenSearchSparkSqlDialect;
 import org.opensearch.sql.common.setting.Settings;
 import org.opensearch.sql.datasource.DataSourceService;
 import org.opensearch.sql.exception.ExpressionEvaluationException;