(paimon) branch master updated: [spark] Improve write table plan explain string (#4311)

[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 82a011774 [spark] Improve write table plan explain string (#4311)
82a011774 is described below

commit 82a011774cde7295b841548de11f3ff3b33a2adb
Author: Xiduo You <ulyssesyo...@gmail.com>
AuthorDate: Thu Oct 17 12:10:56 2024 +0800

    [spark] Improve write table plan explain string (#4311)
---
 .../src/main/scala/org/apache/paimon/spark/SaveMode.scala         | 8 ++++----
 .../src/main/scala/org/apache/paimon/spark/SparkTable.scala       | 4 ++++
 .../src/main/scala/org/apache/paimon/spark/SparkWrite.scala       | 4 ++++
 3 files changed, 12 insertions(+), 4 deletions(-)

diff --git 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SaveMode.scala
 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SaveMode.scala
index c4dae5e3d..bcd6f68ab 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SaveMode.scala
+++ 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SaveMode.scala
@@ -23,15 +23,15 @@ import org.apache.spark.sql.sources.{AlwaysTrue, Filter}
 
 sealed private[spark] trait SaveMode extends Serializable
 
-object InsertInto extends SaveMode
+case object InsertInto extends SaveMode
 
 case class Overwrite(filters: Option[Filter]) extends SaveMode
 
-object DynamicOverWrite extends SaveMode
+case object DynamicOverWrite extends SaveMode
 
-object ErrorIfExists extends SaveMode
+case object ErrorIfExists extends SaveMode
 
-object Ignore extends SaveMode
+case object Ignore extends SaveMode
 
 object SaveMode {
   def transform(saveMode: SparkSaveMode): SaveMode = {
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 e45d15aa9..39b1947e4 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
@@ -107,4 +107,8 @@ case class SparkTable(table: Table)
         throw new RuntimeException("Only FileStoreTable can be written.")
     }
   }
+
+  override def toString: String = {
+    s"${table.getClass.getSimpleName}[${table.fullName()}]"
+  }
 }
diff --git 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkWrite.scala
 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkWrite.scala
index 7e7919592..fd43decfc 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkWrite.scala
+++ 
b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/SparkWrite.scala
@@ -35,4 +35,8 @@ class SparkWrite(val table: FileStoreTable, saveMode: 
SaveMode, options: Options
         WriteIntoPaimonTable(table, saveMode, data, 
options).run(data.sparkSession)
       }
   }
+
+  override def toString: String = {
+    s"table: ${table.fullName()}, saveMode: $saveMode, options: 
${options.toMap}"
+  }
 }