Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

pyflink.datastream.data_stream.KeyedStream.count_window#

KeyedStream.count_window(size: int, slide: int = 0)[source]#

Windows this KeyedStream into tumbling or sliding count windows.

Parameters

  • size – The size of the windows in number of elements.

  • slide – The slide interval in number of elements.

New in version 1.16.0.

previous

pyflink.datastream.data_stream.KeyedStream.window

next

pyflink.datastream.data_stream.KeyedStream.union
On this page
  • KeyedStream.count_window()
Show Source

Created using Sphinx 5.3.0.