Yes, this is a very good explanation, Tony!
I'd like to add that "Evictor" is not really a good name for what it does. It
should be more like "Keeper" or "Retainer" because what a
"CountEvictor.of(1000)" really does is to evict everything but the last 1000
elements, so it should be called "Coun
Hi Jerry,
You can learn about Flink's windowing mechanics in this blog (
https://flink.apache.org/news/2015/12/04/Introducing-windows.html).
To my understanging, window() defines how Flink use WindowAssigner to
insert an element to the right windows, trigger() defines when to fire a
window and e
Hello,
I have a question regarding windowing and triggering. I am trying to
connect the dots between the simple windowing api e.g.
stream.countWindow(1000, 100)
to the underlying representation using triggers and evictors api:
stream.window(GlobalWindows.create())
.evictor(CountEvictor.of(10
