You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@beam.apache.org by "Balogh, György" <bo...@ultinous.com> on 2023/10/19 07:04:48 UTC

implementing cool down?

Hi,
I'm  using beam from java. My pipeline generates alerts.
I'd like to filter alerts with a cool down period: if an alert is emitted,
disable new alerts for a given cool down period (eg: 1 minute).
What would be the best approach to implement this?
Gyorgy

-- 

György Balogh
CTO
E gyorgy.balogh@ultinous.com <zs...@ultinous.com>
M +36 30 270 8342 <+36%2030%20270%208342>
A HU, 1117 Budapest, Budafoki út 209.
W www.ultinous.com

Re: implementing cool down?

Posted by Sachin Mittal <sj...@gmail.com>.

You can try approach mentioned in here:
https://beam.apache.org/blog/timely-processing/


On Thu, Oct 19, 2023 at 12:36 PM Balogh, György <bo...@ultinous.com> wrote:

> Hi,
> I'm  using beam from java. My pipeline generates alerts.
> I'd like to filter alerts with a cool down period: if an alert is emitted,
> disable new alerts for a given cool down period (eg: 1 minute).
> What would be the best approach to implement this?
> Gyorgy
>
> --
>
> György Balogh
> CTO
> E gyorgy.balogh@ultinous.com <zs...@ultinous.com>
> M +36 30 270 8342 <+36%2030%20270%208342>
> A HU, 1117 Budapest, Budafoki út 209.
> W www.ultinous.com
>