flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gabriele Di Bernardo <gabriele.diberna...@me.com>
Subject Find the running median from a data stream
Date Sun, 23 Jul 2017 11:28:00 GMT
Hi guys,

I want to keep track of the running median of a keyed data stream. I was considering to apply
a RichMapFunction to the stream and store in a ValueState object two heaps (PriorityQueue)
in order to find the running median. However, I am not really sure if this is the best approach
performance-wise. Do you have some suggestions for me or have you ever done something similar?

Thank you so much!


View raw message