flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lifei Chen <hust...@gmail.com>
Subject How to calculate moving average result using flink sql ?
Date Tue, 16 Apr 2019 08:07:31 GMT
Hi, all:

I have a `Order` table as follow:

rowtime  item     price
======= ======== ======
09:00   item1      10
09:01   item2      15
09:03   item1       20


I want to calculate the moving average price in past 5 minutes, and emit
the result for every record.
how to do this using flink sql?


Regards
Lifei

Mime
View raw message