Hi Kostas,
I have a similar scenario where i have to clear window elements upon
reaching some count or clear the elements if they are older than one hour.
I'm using the below approach, just wanted to know if its the right way :
DataStream> out = mappedFields
.map(new
Hi Harshith,
The evictor has 2 methods:
void evictBefore(Iterable> elements, int size, W
window, EvictorContext evictorContext);
void evictAfter(Iterable> elements, int size, W window,
EvictorContext evictorContext);
In the iterables, you have access to the elements and their timestamps, and
the
Thanks. That makes sense :)
From: Kostas Kloudas
Date: Friday, 18 January 2019 at 8:25 PM
To: Harshith Kumar Bolar
Cc: "user@flink.apache.org"
Subject: [External] Re: Is there a way to find the age of an element in a
Global window?
Hi Harshith,
The evictor has 2 methods:
void
Hi all,
I'm using Global Windows for my application with a custom trigger and custom
evictor based on some conditions. Now, I also want to evict those elements from
the window that have stayed there for too long, let's say 30 mins. How would I
go about doing this? Is there a utility that Flink
