operator can recover from failures.
>
> Cheers, Fabian
>
>
>
> 2016-04-21 23:16 GMT+02:00 Jonathan Yom-Tov :
>
>> 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 Huesk
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 :
>
>> I
, John Sherwood 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
> wrote:
&g
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 =
