Re: [EXTERNAL] Re: Delayed processing and Rate limiting

2019-08-07 Thread Biao Liu
gt; > > Thanks in advance > > Shakir > > > > *From: *Victor Wong > *Date: *Wednesday, August 7, 2019 at 10:59 AM > *To: *"PoolakkalMukkath, Shakir" , > user > *Subject: *[EXTERNAL] Re: Delayed processing and Rate limiting > > > >

Re: [EXTERNAL] Re: Delayed processing and Rate limiting

2019-08-07 Thread PoolakkalMukkath, Shakir
To: "PoolakkalMukkath, Shakir" , user Subject: [EXTERNAL] Re: Delayed processing and Rate limiting Hi Shakir, > Delayed Processing Maybe you can make use of the function ‘org.apache.flink.streaming.api.TimerService#registerProcessingTimeTimer’, check this doc for more details: https://

Re: Delayed processing and Rate limiting

2019-08-07 Thread Victor Wong
stream/operators/asyncio.html#async-io-api Best, Victor From: "PoolakkalMukkath, Shakir" Date: Wednesday, August 7, 2019 at 10:06 PM To: user Subject: Delayed processing and Rate limiting Hi Flink Team, I am looking for some direction/recommendation for below tasks 1. Delayed Pr

Delayed processing and Rate limiting

2019-08-07 Thread PoolakkalMukkath, Shakir
Hi Flink Team, I am looking for some direction/recommendation for below tasks 1. Delayed Processing: Having a use case where we need to process events after a time-delay from event time. Let’s say, the event happened at time t1, and it reached the Flink immediately, but I have to wait