This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 52034b68f8 [spark] SparkGenericCatalog support tag DDL (#4833)
52034b68f8 is described below
commit 52034b68f81ff677ee1e6fbb66ed0d460afc4e74
Author: cxzl25 <[email protected]>
AuthorDate: Mon Jan 6 14:26:50 2025 +0800
[spark] SparkGenericCatalog support tag DDL (#4833)
---
.../main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala
index fb7bc6b22c..f2bfc7846b 100644
---
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala
+++
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/execution/PaimonStrategy.scala
@@ -18,7 +18,7 @@
package org.apache.paimon.spark.execution
-import org.apache.paimon.spark.{SparkCatalog, SparkUtils}
+import org.apache.paimon.spark.{SparkCatalog, SparkGenericCatalog, SparkUtils}
import org.apache.paimon.spark.catalog.SupportView
import org.apache.paimon.spark.catalyst.analysis.ResolvedPaimonView
import
org.apache.paimon.spark.catalyst.plans.logical.{CreateOrReplaceTagCommand,
CreatePaimonView, DeleteTagCommand, DropPaimonView, PaimonCallCommand,
RenameTagCommand, ResolvedIdentifier, ShowPaimonViews, ShowTagsCommand}
@@ -125,6 +125,8 @@ case class PaimonStrategy(spark: SparkSession)
catalogAndIdentifier.catalog match {
case paimonCatalog: SparkCatalog =>
Some((paimonCatalog, catalogAndIdentifier.identifier()))
+ case paimonCatalog: SparkGenericCatalog =>
+ Some((paimonCatalog, catalogAndIdentifier.identifier()))
case _ =>
None
}