Re: 回复： DataStream problem

Posted by Dawid Wysakowicz-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/DataStream-problem-tp41474p41510.html

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