You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by zs...@apache.org on 2017/02/28 02:02:48 UTC
spark git commit: [SPARK-19749][SS] Name socket source with a
meaningful name
Repository: spark
Updated Branches:
refs/heads/master 16d8472f7 -> 735303835
[SPARK-19749][SS] Name socket source with a meaningful name
## What changes were proposed in this pull request?
Name socket source with a meaningful name
## How was this patch tested?
Jenkins
Author: uncleGen <hu...@gmail.com>
Closes #17082 from uncleGen/SPARK-19749.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/73530383
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/73530383
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/73530383
Branch: refs/heads/master
Commit: 73530383538ad72fdc3dd4c670485192f12ebc4e
Parents: 16d8472
Author: uncleGen <hu...@gmail.com>
Authored: Mon Feb 27 18:02:45 2017 -0800
Committer: Shixiong Zhu <sh...@databricks.com>
Committed: Mon Feb 27 18:02:45 2017 -0800
----------------------------------------------------------------------
.../org/apache/spark/sql/execution/streaming/socket.scala | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/73530383/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala
index 900d92b..58bff27 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/socket.scala
@@ -46,8 +46,8 @@ object TextSocketSource {
* support for fault recovery and keeping all of the text read in memory forever.
*/
class TextSocketSource(host: String, port: Int, includeTimestamp: Boolean, sqlContext: SQLContext)
- extends Source with Logging
-{
+ extends Source with Logging {
+
@GuardedBy("this")
private var socket: Socket = null
@@ -168,6 +168,8 @@ class TextSocketSource(host: String, port: Int, includeTimestamp: Boolean, sqlCo
socket = null
}
}
+
+ override def toString: String = s"TextSocketSource[host: $host, port: $port]"
}
class TextSocketSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org