Hi Luis, these blogposts should help you with the periodic partial result trigger [1] [2].
Regarding the second question: Time windows are by default aligned to 1970-01-01-00:00:00. So a 24 hour window will always start at 00:00. Best, Fabian [1] http://flink.apache.org/news/2015/12/04/Introducing-windows.html [2] https://www.mapr.com/blog/essential-guide-streaming-first-processing-apache-flink 2016-10-27 16:31 GMT+02:00 Luis Mariano Guerra <mari...@event-fabric.com>: > hi, > > I need to calculate some counts for the day but also emit the partial > counts periodically, I think triggers may help me, I'm searching around but > there's not much content about it, any tip? > > for example I'm counting access by location to different services, I want > to accumulate access during the whole day, but I want to emit the partial > count every 5 minutes. > > one slightly related question, is there a way to align a window to a day? > for example a 24 hour window that starts at 00:00. > > thanks. >
