Hi!
If I'm not mistaken, you would like your window to be triggered every 15
minutes, or if there are no activity for 15 minutes?
This seems like an integration of tumbling window and session window. You
can refer to ProcessingTimeSessionWindows for the implementation of a
session window and modi
I use event time,with Kafka as my source.
The system that I am developing requires data to be aggregated every 15
minutes, thus
I am using a Tumbling Event Time window. However, my system also is
required to take
action every 15 minutes even if there is activity.
I need the elements collected in t
