Hi Gaurav, Why do you think the RichAggregateFunction cannot access the State API? RichAggregateFunction inherits from AbstractRichFunction (it provides a RuntimeContext that allows you to access the state API).
Thanks, vino. Gaurav Luthra <gauravluthra6...@gmail.com> 于2018年9月28日周五 下午1:38写道： > 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/ >
