flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Piyush Shrivastava <piyush...@yahoo.co.in>
Subject Operation of Windows and Triggers
Date Wed, 20 Apr 2016 11:20:34 GMT
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
http://webograffiti.com

Mime
View raw message