pyflink.datastream.data_stream.WindowedStream.allowed_lateness

WindowedStream.allowed_lateness(time_ms: int) → WindowedStream

Sets the time by which elements are allowed to be late. Elements that arrive behind the watermark by more than the specified time will be dropped. By default, the allowed lateness is 0.

Setting an allowed lateness is only valid for event-time windows.