flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: implementing a continuous time window
Date Thu, 21 Apr 2016 19:30:25 GMT
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.yomtov@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 <jrs@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.yomtov@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.
>>>
>>
>>
>

Mime
View raw message