Improve write table plan explain string

apache · Oct 11, 2024 · 9f9e03a · 9f9e03a
1 parent c41d23c
commit 9f9e03a
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 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
@@ -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
@@ -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
@@ -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}"
+  }
 }