Skip to content
Snippets Groups Projects
Commit 73530383 authored by uncleGen's avatar uncleGen Committed by Shixiong Zhu
Browse files

[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 <hustyugm@gmail.com>

Closes #17082 from uncleGen/SPARK-19749.
parent 16d8472f
No related branches found
No related tags found
No related merge requests found
......@@ -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 {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment