Hi,
I think you can implement that by writing a custom Trigger that combines
functionality of CountTrigger and EventTimeTrigger. You should keep in mind,
though, that having windows of size 1 hour and slide 5 seconds will lead to a
lot of duplication because in Flink every sliding window is con
Hi,
I would like to implement a custom time based sliding window . The idea is
that the window is of 1 hr size and slides every 5 second. I would like to
process the window function after 10 records are accumulated in the window
till it reaches 1 hr, post that since it slides every 5 second, the w
