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, ?g???U?[???? wrote: > Hi Dawid > > ?0?2 ?0?2 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 > > > ------------------?0?2?????????0?2------------------ > *??????:* "Dawid Wysakowicz" <dwysakow...@apache.org>; > *????????:*?0?22021??2??15??(??????) ????6:59 > *??????:*?0?2"?g???U?[????"<zhoujiazhi1...@vip.qq.com>;"user"<user@flink.apache.org>; > *????:*?0?2Re: 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, ?g???U?[???? wrote: > > Hi all > > ?0?2 ?0?2 ?0?2 ?0?2Using DataStream, How to implement a message and the same > > message appears again 10 minutes later? > > Thanks, > > Jiazhi > >
signature.asc
Description: OpenPGP digital signature
