pyflink.datastream.data_stream.KeyedStream.count_window

KeyedStream.count_window(size: int, slide: int = 0)

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.

Added in version 1.16.0.