Re: Trigger evaluate

No, this is correct. It describes how a Trigger is called, i.e., Flink calls for each element that is inserted into a window the Trigger.onElement() method. The default trigger of a TimeWindow does not fire on new elements. However, a custom trigger might fire when onElement() is called. 2016-10-2

Re: Trigger evaluate

this is a mistake ? *"The trigger is called for each element that is inserted into the window and when a previously registered timer times out"* Thanks !! 2016

Re: Trigger evaluate

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 evalua

Re: Trigger evaluate

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 is related?

Re: Trigger evaluate

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 wrote: > Hello, 1 doubt: > > By default, when Trigger is launch to evaluate data of window ? > - N