You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Avi Levi <av...@bluevoyant.com> on 2019/11/06 10:07:25 UTC

need some advice comparing sliding window to a single unit

Hi,
I want to get the average of the last x hours and compare it to the sum of
the current hour.
I thought of using ProcessWindowFunction for 8 hours and do the calculation
i.e consuming 8 hours of data and group it by the hour and do the math, but
it seems very inefficient especially considering that we are dealing with
heavy load.
is there any other more elegant solution ?

Cheers
Avi