Hi, I think you could return a proper TriggerResult, which defines how to deal with the window elements after computing a window in your trigger implementation. You could find the detail information from the doc[1].
1. https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/operators/windows.html#fire-and-purge Best, Guowei M Singh <mans2si...@yahoo.com> 于2019年4月11日周四 上午1:42写道： > Hi: > > I have a use case where I need to create a global window where I need to > wait for unknown time for certain events for a particular key. I > understand that I can create a global window and use a custom trigger to > initiate the function computation. But I am not sure how to destroy the > window after the triggering conditions is satisfied and the the events are > purged. > > If there is any better way of dealing with this situation, please let me > know. > > Thanks > > Mans >
