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 <bog...@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.bal...@ultinous.com <zsolt.sala...@ultinous.com> > M +36 30 270 8342 <+36%2030%20270%208342> > A HU, 1117 Budapest, Budafoki út 209. > W www.ultinous.com >
