I also met the same issue. Any updates on this?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Windowed-Operations-tp15133p23094.html
Sent from the Apache Spark User List mailing list archive at Nabble.com
), Seconds(30))
w2.print()
then w1 works, but w2 always does not print any information.
Do you have any update for this issue?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Windowed-Operations-tp15133p16128.html
Sent from the Apache Spark User List
Hi everyone,
I'm trying to understand the windowed operations functioning. What I want to
achieve is the following:
val ssc = new StreamingContext(sc, Seconds(1))
val lines = ssc.socketTextStream("localhost", )
val window5 = lines.window(Seconds(5),Seconds(5)
