Skip to main content
Ctrl+K
PyFlink 1.20+vvr.11.7.dev0 documentation - Home PyFlink 1.20+vvr.11.7.dev0 documentation - Home
  • API Reference
  • Examples
  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Asynchronous I/O
    • Connectors
    • Formats
  • PyFlink DataFrame
  • PyFlink Common
  • API Reference
  • PyFlink DataStream
  • DataStream
  • pyflink.datastream.data_stream.AllWindowedStream.allowed_lateness

pyflink.datastream.data_stream.AllWindowedStream.allowed_lateness#

AllWindowedStream.allowed_lateness(time_ms: int) → AllWindowedStream[source]#

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.

previous

pyflink.datastream.data_stream.AllWindowedStream.trigger

next

pyflink.datastream.data_stream.AllWindowedStream.side_output_late_data
On this page
  • AllWindowedStream.allowed_lateness()

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.