Re: Flink sql problem

Posted by Timo Walther on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-sql-problem-tp41019p41159.html

Hi Jiazhi,

I think an OVER window might solve your use case. It gives you a rolling
aggregation over period of time. Maybe you need to define a custom
aggregate function to emit the final record as you need it.

Let me know if you have further questions.

Regards,
Timo


On 27.01.21 15:02, ゞ野蠻遊戲χ wrote:
> Hi all
>
>            After grouping by users, message A arrives. If message B also
> arrives later, and the time of message B is less than that of message A
> within 10 minutes, mark the field in message A with Tag = True. How to
> achieve this?
>
> Thanks
> Jiazhi