Hii, Team I have one specific use case which I am describing below, I have tried so many things, and read blogs but with no success. it would be very helpful if you guys can help. 🙏 So I have a table with columns

pair_id | price | time

and I get these data as a continuous stream and I want to calculate the percentage change of the price for the last 5 minutes for each unique

pair_id

. Can you please provide some assistance in python? Many thanks.

That's going to be easiest to do with an OVER window: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/sql/queries/over-agg/#over-aggregation

Thanks @David Anderson I'll try this.