ld my own rate limiter.
>
>
>
> 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 Ra
: "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://
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
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 t1+2m
