pyflink.table.window.Slide.over

classmethod Slide.over(size: pyflink.table.expression.Expression) → pyflink.table.window.SlideWithSize

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.