pyflink.datastream.window.CountWindow

class CountWindow(id: int)

A Window that represents a count window. For each count window, we will assign a unique id. Thus this CountWindow can act as namespace part in state. We can attach data to each different CountWindow.

Methods

max_timestamp()