From 39a132f58092b81675bf271977cb13ba6b5dc428 Mon Sep 17 00:00:00 2001 From: Jacek Laskowski Date: Wed, 5 Jul 2017 10:15:37 +0200 Subject: [PATCH 1/2] [SPARK-21313][SS] ConsoleSink's string representation --- .../org/apache/spark/sql/execution/streaming/console.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/console.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/console.scala index 3baea6376069f..1c9284e252bd6 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/console.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/console.scala @@ -52,6 +52,8 @@ class ConsoleSink(options: Map[String, String]) extends Sink with Logging { data.sparkSession.sparkContext.parallelize(data.collect()), data.schema) .show(numRowsToShow, isTruncated) } + + override def toString(): String = s"ConsoleSink[numRows=$numRowsToShow, truncate=$isTruncated]" } case class ConsoleRelation(override val sqlContext: SQLContext, data: DataFrame) From cff82eea2ce7ac6b671cc57ba9836dd071464d9b Mon Sep 17 00:00:00 2001 From: Jacek Laskowski Date: Thu, 6 Jul 2017 14:03:40 +0200 Subject: [PATCH 2/2] ForeachSink#toString --- .../org/apache/spark/sql/execution/streaming/ForeachSink.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ForeachSink.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ForeachSink.scala index de09fb568d2a6..2cc54107f8b83 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ForeachSink.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ForeachSink.scala @@ -63,4 +63,6 @@ class ForeachSink[T : Encoder](writer: ForeachWriter[T]) extends Sink with Seria } } } + + override def toString(): String = "ForeachSink" }