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 the aggregation phase to emmit. How can this be done with triggers? I noticed the ProcessingTimeoutTrigger, but I am not sure how to use it.
