You will have to define your own stream-to-iterator function and use the socketStream. The function should return custom delimited object as bytes are continuously coming in. When data is insufficient, the function should block.
TD On Jul 23, 2014 6:52 PM, "kytay" <kaiyang....@gmail.com> wrote: > Hi TD > > You are right, I did not include "\n" to delimit the string flushed. That's > the reason. > > Is there a way for me to define the delimiter? Like SOH or ETX instead of > "\n" > > Regards > kytay > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Solved-Streaming-Cannot-get-socketTextStream-to-receive-anything-tp9382p10558.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. >
