DataStream problem

[ゞ野蠻遊戲χ]

Hi all

       Using DataStream, How to implement a message and the same message appears again 10 minutes later?

Thanks,

Jiazhi

[Dawid Wysakowicz-2]

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

[Dawid Wysakowicz-2]

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" [hidden email];

发送时间: 2021年2月15日(星期一) 晚上6:59

收件人: "ゞ野蠻遊戲χ"[hidden email];"user"[hidden email];

主题: 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