Hi all, I want to compute the average of two stream data sources and also keep track of a ValueState variable which is a CountMinSketch class that I implemented. For this, I tried to use RichAggregateFunction however it throws an exception saying that - Exception in thread "main" java.lang.UnsupportedOperationException: This aggregation function cannot be a RichFunction.
Here is the code that I am implementing together with the line that is compiling but says that Flink does not support it - https://github.com/felipegutierrez/explore-flink/blob/master/src/main/java/org/sense/flink/examples/stream/MultiSensorMultiStationsReadingMqtt2.java#L70 How would I implement this in Flink? Thanks for your ideas Felipe *--* *-- Felipe Gutierrez* *-- skype: felipe.o.gutierrez* *--* *https://felipeogutierrez.blogspot.com <https://felipeogutierrez.blogspot.com>*
