add description

linhongliu-db · linhongliu-db · commit e48aee512db1 · 2021-05-13T19:31:35.000+08:00
diff --git a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaWrite.scala b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaWrite.scala
@@ -27,6 +27,8 @@ case class KafkaWrite(
     producerParams: ju.Map[String, Object],
     schema: StructType) extends Write {
 
+  override def description(): String = "Kafka"
+
   override def toBatch: BatchWrite = {
     assert(schema != null)
     new KafkaBatchWrite(topic, producerParams, schema)
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileWrite.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/FileWrite.scala
@@ -47,6 +47,8 @@ trait FileWrite extends Write {
   private val queryId = info.queryId()
   private val options = info.options()
 
+  override def description(): String = formatName
+
   override def toBatch: BatchWrite = {
     val sparkSession = SparkSession.active
     validateInputs(sparkSession.sessionState.conf.caseSensitiveAnalysis)
