Hi, As we are aware, Currently we cannot use RichAggregateFunction in aggregate() method upon windowed stream. So, To access the state in your customAggregateFunction, you can implement it using a ProcessFuntion. This issue is faced by many developers. So, someone must have implemented or tried to implement it. So, kindly share your feedback on this. As I need to implement this.
Thanks & Regards Gaurav Luthra -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
