Three minutes as a time window, remember the first time id is 1, the second three minutes appear to 2, the third of three minutes no interruptions in a row, the fourth three minutes appear to 1 this in Spark Streaming it should do

CodePudding user response:

Can draw lessons from Streaming wordCount program, he is statistics and statistics, you are just before did not appear the ID when you put the statistics of the data set to 0