Hi, You need to implement your own timer. You do this when you create your window by assigning the timer. In your custom timer you would need to implement the desired logic in the onElement method. You can keep a counter that you increment for each element up to your desired number of elements and FIRE only when this value is reaches your threshold after which you want to trigger
You can take a look in existing triggers https://github.com/apache/flink/tree/1875cac03042dad4a4c47b0de8364f02fbe457c6/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers -----Original Message----- From: madhairsilence [mailto:harish.kum...@tcs.com] Sent: Thursday, April 13, 2017 12:25 PM To: dev@flink.apache.org Subject: Re: Sliding Window - Weird behaviour Hi Xingcan Thanks for the answer. But up to my understanding countWindow(4,2) - Should wait for 4 elements (or window not more than 4 element) and once the window is ready, slide two items Now if I have to stopped asking why questions and worry about my current problem, how do I achieve this expected output. Stream : 1,2,3,4,5,6,7,8... Output: 1,2 2,3 3,4 4,5... -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Sliding-Window-Weird-behaviour-tp17013p17019.html Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.
