Hi all, I need to configure a keyed global window that would trigger a reduce function for all the events in each key group before the processing finishes and the job closes.
I have something similar for the realtime(streaming) version of the job, configured with a processing time gap: .keyBy (new MyKeySelector ()) .window (ProcessingTimeSessionWindows.withGap (timeWindowInSeconds)) .reduce (new MyReduceFunction ()) However for the batch version of the job (reprocessing of the data), I would not use any time gap but rather a global window that would close and reduce just before the job ends. Is that possible? I’ve seen that the global window does not have any trigger implemented by default. How can I implement/use a trigger that would trigger before job finishes?
