You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2021/02/19 11:35:16 UTC
Flink problem
hi all
For example, if A user message A (uerId: 001) is reported, and no record is reported again by userId: 001 within 10 minutes, record A will be sent out. How can this be achieved in Flink?
Thanks
Jiazhi
发自我的iPhone
Re: Flink problem
Posted by Guanghui Zhang <be...@gmail.com>.
Can you tell what to do when the record is reported again by userId:001
within 10 minutes, for example buffer it or keep the only one ？
ゞ野蠻遊戲χ <zh...@vip.qq.com> 于2021年2月19日周五 下午7:35写道：
> hi all
>
> For example, if A user message A (uerId: 001) is reported, and no
> record is reported again by userId: 001 within 10 minutes, record A will be
> sent out. How can this be achieved in Flink?
>
> Thanks
> Jiazhi
>
> ------------------------------
> 发自我的iPhone
>
Re: Flink problem
Posted by Xintong Song <to...@gmail.com>.
What you're looking for might be Session Window[1].
Thank you~
Xintong Song
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/operators/windows.html#session-windows
On Fri, Feb 19, 2021 at 7:35 PM ゞ野蠻遊戲χ <zh...@vip.qq.com> wrote:
> hi all
>
> For example, if A user message A (uerId: 001) is reported, and no
> record is reported again by userId: 001 within 10 minutes, record A will be
> sent out. How can this be achieved in Flink?
>
> Thanks
> Jiazhi
>
> ------------------------------
> 发自我的iPhone
>