I'm new to Spark Streaming. From the programming guide I saw there is this JavaStreamingContext.socketTextStream() API that connects to a server and grab the content to process. My requirement is a slightly different: I used to have listening server that receives (not go out to grab) messages from an external source, then process each message. I'm wondering if Spark Streaming can support this kind of "socket communication", i.e. start a listening server socket at a port, then process each message it receives.
I'm not sure if my understanding of the semantics of the JavaStreamingContext.socketTextStream() API is correct. So I'm not sure if my question above is valid or not. I'll greatly appreciate any help. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-with-Listening-Server-Socket-tp21021.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
