update syntax from project to view

Signed-off-by: YANGDB <[email protected]>
opensearch-project · Dec 13, 2024 · 0d55aa8 · 0d55aa8
1 parent bfbb555
commit 0d55aa8
Show file tree

Hide file tree

Showing 5 changed files with 3 additions and 5 deletions.
diff --git a/.../integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLViewStatementITSuite.scala b/.../integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLViewStatementITSuite.scala
@@ -8,7 +8,6 @@ package org.opensearch.flint.spark.ppl
 import java.nio.file.{Files, Paths}
 
 import org.apache.spark.sql.{AnalysisException, QueryTest, Row}
-import org.apache.spark.sql.catalyst.TableIdentifier
 import org.apache.spark.sql.catalyst.analysis.{UnresolvedAttribute, UnresolvedFunction, UnresolvedIdentifier, UnresolvedRelation, UnresolvedStar}
 import org.apache.spark.sql.catalyst.expressions.{Alias, Ascending, Descending, Divide, EqualTo, Floor, GreaterThan, IsNotNull, Literal, Multiply, Not, Or, SortOrder}
 import org.apache.spark.sql.catalyst.plans.Inner

diff --git a/ppl-spark-integration/src/main/antlr4/OpenSearchPPLParser.g4 b/ppl-spark-integration/src/main/antlr4/OpenSearchPPLParser.g4
@@ -82,7 +82,6 @@ commandName
    | EVAL
    | GROK
    | PARSE
-   | PROJECT
    | PATTERNS
    | LOOKUP
    | RENAME

diff --git a/ppl-spark-integration/src/main/java/org/opensearch/sql/ast/AbstractNodeVisitor.java b/ppl-spark-integration/src/main/java/org/opensearch/sql/ast/AbstractNodeVisitor.java
@@ -142,7 +142,7 @@ public T visitView(View node, C context) {
     return visitChildren(node, context);
   }
 
-  public T visitProjectStatement(ViewStatement node, C context) {
+  public T visitViewStatement(ViewStatement node, C context) {
     return visitChildren(node, context);
   }
 

diff --git a/ppl-spark-integration/src/main/java/org/opensearch/sql/ast/statement/ViewStatement.java b/ppl-spark-integration/src/main/java/org/opensearch/sql/ast/statement/ViewStatement.java
@@ -65,7 +65,7 @@ public QualifiedName getTableQualifiedName() {
 
     @Override
     public <R, C> R accept(AbstractNodeVisitor<R, C> visitor, C context) {
-        return visitor.visitProjectStatement(this, context);
+        return visitor.visitViewStatement(this, context);
     }
 
 }
diff --git a/ppl-spark-integration/src/main/java/org/opensearch/sql/ppl/CatalystQueryPlanVisitor.java b/ppl-spark-integration/src/main/java/org/opensearch/sql/ppl/CatalystQueryPlanVisitor.java
@@ -133,7 +133,7 @@ public LogicalPlan visitFirstChild(Node node, CatalystPlanContext context) {
     }
 
     @Override
-    public LogicalPlan visitProjectStatement(ViewStatement node, CatalystPlanContext context) {
+    public LogicalPlan visitViewStatement(ViewStatement node, CatalystPlanContext context) {
         node.getStatement().accept(this, context);
         return context.apply(p -> ViewUtils.visitView(p, node, context));
     }