flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: emit partial state in window (streaming)
Date Thu, 27 Oct 2016 14:37:17 GMT
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

2016-10-27 16:31 GMT+02:00 Luis Mariano Guerra <mariano@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.

View raw message