pyflink.datastream.data_stream.WindowedStream.trigger

WindowedStream.trigger(trigger: pyflink.datastream.window.Trigger) → pyflink.datastream.data_stream.WindowedStream

Sets the Trigger that should be used to trigger window emission.