From 2ffe4476553cfe50eb6392d8e573545a92fef737 Mon Sep 17 00:00:00 2001 From: Jacek Laskowski Date: Tue, 9 May 2017 10:20:49 +0200 Subject: [PATCH 1/2] [SPARK-20600][SQL] KafkaRelation should be pretty printed in web UI (Details for Query) --- .../scala/org/apache/spark/sql/kafka010/KafkaRelation.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala index 97bd283169323..bfbcab47a0c78 100644 --- a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala +++ b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala @@ -143,4 +143,6 @@ private[kafka010] class KafkaRelation( validateTopicPartitions(partitions, partitionOffsets) } } + + override def toString: String = "kafka" } From 02d0d3ed1499ae07866fc2bd94f1744e1f0368fc Mon Sep 17 00:00:00 2001 From: Jacek Laskowski Date: Thu, 11 May 2017 18:27:12 +0200 Subject: [PATCH 2/2] After review #1 --- .../scala/org/apache/spark/sql/kafka010/KafkaRelation.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala index bfbcab47a0c78..7103709969c18 100644 --- a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala +++ b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala @@ -144,5 +144,6 @@ private[kafka010] class KafkaRelation( } } - override def toString: String = "kafka" + override def toString: String = + s"KafkaRelation(strategy=$strategy, start=$startingOffsets, end=$endingOffsets)" }