Re: time window and reduce problem

Hi Jiazhi, not sure if I got the question correctly, but the reduce function will be repeatedly applied to all elements in your tumbling window until only one final aggregate per key and window remains. So in your case, you would get the user with the max id per UserBehavior(?) for each 30 secs w

time window and reduce problem

Deal All        I use the reduce operator after the TimeWindow operator, whether to output one element after all elements in the current window have been calculated according to reduce logic?? Thanks Jiazhi