Hi all, I have a requirement where I have to implement an internal UDF for flink where I need to maintain the state and also return response for every event using the state for a given window. Which function should I extend? I was thinking of key processed function or table aggregate function but it seem Flink SQL does not support these functions. Any suggestions on how can this be implemented?