pyflink.table.window.Slide.over#
- classmethod Slide.over(size: Expression) SlideWithSize[source]#
Creates a sliding window. Sliding windows have a fixed size and slide by a specified slide interval. If the slide interval is smaller than the window size, sliding windows are overlapping. Thus, an element can be assigned to multiple windows.
For example, a sliding window of size 15 minutes with 5 minutes sliding interval groups elements of 15 minutes and evaluates every five minutes. Each element is contained in three consecutive window evaluations.
- Parameters:
size – The size of the window as time or row-count interval.
- Returns:
A partially specified sliding window.