flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Trigger evaluate
Date Mon, 24 Oct 2016 18:45:00 GMT
The window is evaluated when a watermark arrives that is behind the
window's end time.

For instance, give the window in your example there are windows that end at
1:00:00, 1:00:30, 1:01:00, 1:01:30, ... (every 30 seconds).
given the windows above, the window from 00:59:00 to 1:00:00 will be
evaluated, when a watermark of 1:00:00 or later is received. It might also
happen that multiple windows are evaluated if watermarks are more than 30
seconds apart.

Best, Fabian

2016-10-24 20:38 GMT+02:00 Alberto Ramón <a.ramonportoles@gmail.com>:

> I mean about *default Trigge*r, when you only put this:
>
>  .timeWindow(Time.minutes(1), Time.seconds(30))
>   .sum(1)
>
> When data window is evaluated ?
>
> this <https://github.com/apache/flink/tree/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers>
is related?
>
>
>
> 2016-10-24 19:39 GMT+02:00 Aljoscha Krettek <aljoscha@apache.org>:
>
>> Hi,
>> this depends on the Trigger you're using. For example, EventTimeTrigger
>> will trigger when the watermark passes the end of a window.
>>
>> Cheers,
>> Aljoscha
>>
>> On Mon, 24 Oct 2016 at 17:10 Alberto Ramón <a.ramonportoles@gmail.com>
>> wrote:
>>
>>> Hello, 1 doubt:
>>>
>>> By default, when Trigger is launch to evaluate data of window ?
>>>  - New element in window?
>>>  - When a watermark arrive?
>>>  - When the window is moved?
>>>
>>> Thanks , Alb
>>>
>>
>

Mime
View raw message