Hi all, I have a keyed operator with an hourly event time trigger. On a timer trigger, the operator simply persists some state to a table.
I'd like to know when the triggers for all keys have finished so I can send a further signal to the data warehouse, to indicate it has all the necessary data to start producing a report. How can I achieve this? If my operator is distributed across different machine tasks I need to make sure I don't send the signal to the data warehouse before the timers for every key have fired. Thanks, Eduardo
