[spark] support 'SHOW VIEWS FROM' syntax (#6873)

Author: YannByron

paimon-spark/paimon-spark-3.2/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/RewritePaimonViewCommands.scala

@@ -23,6 +23,7 @@ import org.apache.paimon.spark.catalyst.plans.logical.{CreatePaimonView, DropPai
 
 import org.apache.spark.sql.SparkSession
 import org.apache.spark.sql.catalyst.analysis.{CTESubstitution, ResolvedNamespace, UnresolvedView}
+import org.apache.spark.sql.catalyst.analysis.SimpleAnalyzer.ResolveNamespace
 import org.apache.spark.sql.catalyst.plans.logical._
 import org.apache.spark.sql.catalyst.rules.Rule
 import org.apache.spark.sql.connector.catalog.{CatalogManager, LookupCatalog}
@@ -60,11 +61,13 @@ case class RewritePaimonViewCommands(spark: SparkSession)
     case DropView(ResolvedIdent(resolved), ifExists: Boolean) =>
       DropPaimonView(resolved, ifExists)
 
-    case ShowViews(_, pattern, output) if catalogManager.currentCatalog.isInstanceOf[SupportView] =>
-      ShowPaimonViews(
-        ResolvedNamespace(catalogManager.currentCatalog, catalogManager.currentNamespace),
-        pattern,
-        output)
+    case ShowViews(namespace, pattern, output)
+        if catalogManager.currentCatalog.isInstanceOf[SupportView] =>
+      val resolvedNamespace = ResolveNamespace(catalogManager)(namespace).transform {
+        case r: ResolvedNamespace if r.namespace.isEmpty =>
+          r.copy(namespace = catalogManager.currentNamespace)
+      }
+      ShowPaimonViews(resolvedNamespace, pattern, output)
   }
 
   private def isTempView(nameParts: Seq[String]): Boolean = {

paimon-spark/paimon-spark-3.3/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/RewritePaimonViewCommands.scala

@@ -23,6 +23,7 @@ import org.apache.paimon.spark.catalyst.plans.logical.{CreatePaimonView, DropPai
 
 import org.apache.spark.sql.SparkSession
 import org.apache.spark.sql.catalyst.analysis.{CTESubstitution, ResolvedNamespace, UnresolvedDBObjectName, UnresolvedView}
+import org.apache.spark.sql.catalyst.analysis.SimpleAnalyzer.ResolveNamespace
 import org.apache.spark.sql.catalyst.plans.logical._
 import org.apache.spark.sql.catalyst.rules.Rule
 import org.apache.spark.sql.connector.catalog.{CatalogManager, LookupCatalog}
@@ -59,11 +60,13 @@ case class RewritePaimonViewCommands(spark: SparkSession)
     case DropView(ResolvedIdent(resolved), ifExists: Boolean) =>
       DropPaimonView(resolved, ifExists)
 
-    case ShowViews(_, pattern, output) if catalogManager.currentCatalog.isInstanceOf[SupportView] =>
-      ShowPaimonViews(
-        ResolvedNamespace(catalogManager.currentCatalog, catalogManager.currentNamespace),
-        pattern,
-        output)
+    case ShowViews(namespace, pattern, output)
+        if catalogManager.currentCatalog.isInstanceOf[SupportView] =>
+      val resolvedNamespace = ResolveNamespace(catalogManager)(namespace).transform {
+        case r: ResolvedNamespace if r.namespace.isEmpty =>
+          r.copy(namespace = catalogManager.currentNamespace)
+      }
+      ShowPaimonViews(resolvedNamespace, pattern, output)
   }
 
   private def isTempView(nameParts: Seq[String]): Boolean = {

paimon-spark/paimon-spark-common/src/main/scala/org/apache/spark/sql/catalyst/parser/extensions/RewritePaimonViewCommands.scala

@@ -22,7 +22,7 @@ import org.apache.paimon.spark.catalog.SupportView
 import org.apache.paimon.spark.catalyst.plans.logical.{CreatePaimonView, DropPaimonView, ResolvedIdentifier, ShowPaimonViews}
 
 import org.apache.spark.sql.SparkSession
-import org.apache.spark.sql.catalyst.analysis.{CTESubstitution, ResolvedNamespace, UnresolvedIdentifier}
+import org.apache.spark.sql.catalyst.analysis.{CTESubstitution, ResolveCatalogs, ResolvedNamespace, UnresolvedIdentifier}
 import org.apache.spark.sql.catalyst.plans.logical._
 import org.apache.spark.sql.catalyst.rules.Rule
 import org.apache.spark.sql.connector.catalog.{CatalogManager, LookupCatalog}
@@ -59,11 +59,13 @@ case class RewritePaimonViewCommands(spark: SparkSession)
     case DropView(ResolvedIdent(resolved), ifExists: Boolean) =>
       DropPaimonView(resolved, ifExists)
 
-    case ShowViews(_, pattern, output) if catalogManager.currentCatalog.isInstanceOf[SupportView] =>
-      ShowPaimonViews(
-        ResolvedNamespace(catalogManager.currentCatalog, catalogManager.currentNamespace),
-        pattern,
-        output)
+    case ShowViews(namespace, pattern, output)
+        if catalogManager.currentCatalog.isInstanceOf[SupportView] =>
+      val resolvedNamespace = new ResolveCatalogs(catalogManager)(namespace).transform {
+        case r: ResolvedNamespace if r.namespace.isEmpty =>
+          r.copy(namespace = catalogManager.currentNamespace)
+      }
+      ShowPaimonViews(resolvedNamespace, pattern, output)
   }
 
   private def isTempView(nameParts: Seq[String]): Boolean = {

paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/PaimonViewTestBase.scala

@@ -84,6 +84,17 @@ abstract class PaimonViewTestBase extends PaimonHiveTestBase {
                     Row("test_db", "va", false),
                     Row("test_db", "vab", false),
                     Row("test_db", "vc", false)))
+
+                // show views from database
+                sql(s"USE $hiveDbName")
+                checkAnswer(
+                  sql("SHOW VIEWS FROM test_db"),
+                  Seq(
+                    Row("test_db", "va", false),
+                    Row("test_db", "vab", false),
+                    Row("test_db", "vc", false)))
+                sql("USE test_db")
+
                 checkAnswer(
                   sql("SHOW VIEWS LIKE 'va*'"),
                   Seq(Row("test_db", "va", false), Row("test_db", "vab", false)))