flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Operation of Windows and Triggers
Date Wed, 20 Apr 2016 11:29:00 GMT
Hi Piyush,

if you explicitly set a trigger, the default trigger of the window is
replaced.
In your example, the time trigger is replaced by the count trigger, i.e.,
the window is only evaluated after the 100th element was received.

This blog post discusses windows and triggers [1].

Best, Fabian

[1] http://flink.apache.org/news/2015/12/04/Introducing-windows.html

2016-04-20 13:20 GMT+02:00 Piyush Shrivastava <piyushjoy@yahoo.co.in>:

> I wanted to know how Windows and Triggers work in Flink. I am creating a
> time window of 20 seconds and a count trigger of 100.
>
> stream.keyBy(0)
>              .timeWindow(Time.seconds(20))
>              .trigger(CountTrigger.of(100))
>
> In this case, when will my window get triggered? When 20 seconds has
> passed, 100 messages are passed?
>
> Thanks and Regards,
> Piyush Shrivastava <piyush@webograffiti.com>
> [image: WeboGraffiti]
> http://webograffiti.com
>

Mime
View raw message