Hi,
I have some thoughts about Evictors as well yes, but I didn’t yet write them
down. The basic idea about them is this:
class Evictor {
Predicate getPredicate(Iterable> elements, int size, W
window);
}
class Predicate {
boolean evict(StreamRecord element);
}
The evictor will return a pr
Thanks for the write-up Aljoscha.
I think it is a really good idea to separate the different aspects (fire,
purging, lateness) a bit. At the moment, all of these need to be handled in
the Trigger and a custom trigger is necessary whenever, you want some of
these aspects slightly differently handled
Hi,
my previous message might be a bit hard to parse for people that are not very
deep into the Trigger implementation. So I’ll try to give a bit more
explanation right in the mail.
The basic idea is that we observed some basic problems that keep coming up for
people on the mailing lists and I
