Re: 回复： DataStream problem

[Dawid Wysakowicz <dw...@apache.org>]

I am sure you can achieve that with a ProcessFunction[1]

Best,

Dawid

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/stream/operators/process_function.html#process-function

On 16/02/2021 07:28, ゞ野蠻遊戲χ wrote:
> Hi Dawid
>
>     For example, if user 001 takes an order and generates an order
> message 1, I need to monitor if user 001 takes another order and
> generates a new order message 2 within 10 minutes. If user 001
> produces an order message 2 again within 10 minutes, I need to mark
> true in the 2 message and output it
>
>
> ------------------ 原始邮件 ------------------
> *发件人:* "Dawid Wysakowicz" <dw...@apache.org>;
> *发送时间:* 2021年2月15日(星期一) 晚上6:59
> *收件人:* "ゞ野蠻遊戲χ"<zh...@flink.apache.org>;
> *主题:* Re: DataStream problem
>
> Hi Jiazhi,
>
> Could you elaborate what exactly do you want to achieve? What have you
> tried so far?
>
> Best,
>
> Dawid
>
> On 15/02/2021 11:11, ゞ野蠻遊戲χ wrote:
> > Hi all
> >        Using DataStream, How to implement a message and the same
> > message appears again 10 minutes later?
> > Thanks,
> > Jiazhi
>
>