Thanks. Any pointers on how to do that? Or code examples which do similar things?
On Thu, Apr 21, 2016 at 10:30 PM, Fabian Hueske <fhue...@gmail.com> wrote: > Yes, sliding windows are different. > You want to evaluate the window whenever a new element arrives or an > element leaves because 5 secs passed since it entered the window, right? > > I think that should be possible with a GlobalWindow, a custom Trigger > which holds state about the time when each element in the window entered > the window, and an Evictor. > > 2016-04-21 21:19 GMT+02:00 Jonathan Yom-Tov <jon.yom...@gmail.com>: > >> I think sliding windows are different. In the example in the blog post a >> window is computed every 30 seconds (so at fixed time intervals). What I >> want is for a window to be computed every time an event comes in and then >> once again when the event leaves the window. >> >> On Thu, Apr 21, 2016 at 10:14 PM, John Sherwood <j...@vt.edu> wrote: >> >>> You are looking for sliding windows: >>> https://flink.apache.org/news/2015/12/04/Introducing-windows.html >>> >>> Here you would do >>> >>> .timeWindow(Time.seconds(5), Time.seconds(1)) >>> >>> On Thu, Apr 21, 2016 at 12:06 PM, Jonathan Yom-Tov <jon.yom...@gmail.com >>> > wrote: >>> >>>> hi, >>>> >>>> Is it possible to implement a continuous time window with flink? Here's >>>> an >>>> example. Say I want to count events within a window. The window length >>>> is 5 >>>> seconds and I get events at t = 1, 2, 7, 8 seconds. I would then expect >>>> to >>>> get events with a count at t = 1 (count = 1), t = 2 (count = 2), t = 6 >>>> (count = 1), t = 7 (count = 2), t = 8 (count = 2), t = 12 (count = 1) >>>> and t >>>> = 13 (count = 0). >>>> >>>> How would I go about doing that?. >>>> >>>> thanks, >>>> Jon. >>>> >>> >>> >> >
