Re: How do I compute the average and keep track of a state over a window in DataStream?

thanks Congxian. I will check Process Function over windows. *--* *-- Felipe Gutierrez* *-- skype: felipe.o.gutierrez* *--* *https://felipeogutierrez.blogspot.com * On Fri, Mar 1, 2019 at 8:16 AM Congxian Qiu wrote: > Hi Felipe > > Maybe you could use

Re: How do I compute the average and keep track of a state over a window in DataStream?

Hi Felipe Maybe you could use process function[1] [1]  https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/operators/process_function.html Best, Congxian On Feb 28, 2019, 22:47 +0800, Felipe Gutierrez , wrote: > Hi all, > > I want to compute the average of two stream data

How do I compute the average and keep track of a state over a window in DataStream?

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"