Hi Guys, I am wondering if Samza supports having multiple windows in one Samza job. So far, haven't found out any information about that.
A simple use case is that, we want to count the events every 10s, 30s, etc. (yes, of course, we can just sum the last three 10s' results to get 30s' result...but that is not what I mean...). Basically, we want to trigger different activities in different intervals. How do you guys deal with this kind of use case in Samza? Currently, I am using another Samza job to do another interval task and feeling that is a little overkill because sometimes all the code in the process() method of StreamTask is exactly the same; the difference is only in window() method. Thank you. Cheers, Fang, Yan [email protected] +1 (206) 849-4108
