From 36497682af2ab4188304452d6de88cd1aeab0dbe Mon Sep 17 00:00:00 2001 From: sychen Date: Fri, 3 Jan 2025 17:00:04 +0800 Subject: [PATCH] SparkGenericCatalog support tag DDL --- .../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 fb7bc6b22cd3..f2bfc7846b90 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 }