(paimon) branch master updated: [spark] SparkTable.name() returning a table name with database (#3680)

[lzljs3620320]

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 8bd9a62de [spark] SparkTable.name() returning a table name with 
database (#3680)
8bd9a62de is described below

commit 8bd9a62de551cd141ac890477f9669742b42745a
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Fri Jul 5 14:07:46 2024 +0800

    [spark] SparkTable.name() returning a table name with database (#3680)
---
 .../src/main/java/org/apache/paimon/table/FileStoreTable.java       | 6 ++++++
 paimon-core/src/main/java/org/apache/paimon/table/Table.java        | 4 ++++
 .../src/main/scala/org/apache/paimon/spark/SparkTable.scala         | 2 +-
 3 files changed, 11 insertions(+), 1 deletion(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java 
b/paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java
index 212555d7b..7c791bd47 100644
--- a/paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java
+++ b/paimon-core/src/main/java/org/apache/paimon/table/FileStoreTable.java
@@ -22,6 +22,7 @@ import org.apache.paimon.FileStore;
 import org.apache.paimon.data.InternalRow;
 import org.apache.paimon.io.DataFileMeta;
 import org.apache.paimon.manifest.ManifestCacheFilter;
+import org.apache.paimon.schema.SchemaManager;
 import org.apache.paimon.schema.TableSchema;
 import org.apache.paimon.stats.SimpleStats;
 import org.apache.paimon.table.query.LocalTableQuery;
@@ -45,6 +46,11 @@ public interface FileStoreTable extends DataTable {
         return location().getName();
     }
 
+    @Override
+    default String fullName() {
+        return SchemaManager.fromPath(location().toUri().toString(), 
true).getFullName();
+    }
+
     @Override
     default RowType rowType() {
         return schema().logicalRowType();
diff --git a/paimon-core/src/main/java/org/apache/paimon/table/Table.java 
b/paimon-core/src/main/java/org/apache/paimon/table/Table.java
index 5f35c4be4..aef5e9f48 100644
--- a/paimon-core/src/main/java/org/apache/paimon/table/Table.java
+++ b/paimon-core/src/main/java/org/apache/paimon/table/Table.java
@@ -45,6 +45,10 @@ public interface Table extends Serializable {
     /** A name to identify this table. */
     String name();
 
+    default String fullName() {
+        return name();
+    }
+
     /** Returns the row type of this table. */
     RowType rowType();
 
diff --git 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala
 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala
index 274619323..902619f05 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala
+++ 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkTable.scala
@@ -44,7 +44,7 @@ case class SparkTable(table: Table)
 
   def getTable: Table = table
 
-  override def name: String = table.name
+  override def name: String = table.fullName
 
   override lazy val schema: StructType = 
SparkTypeUtils.fromPaimonRowType(table.rowType)