pyflink.table.expressions.row_interval

row_interval(rows: int) → Expression

Creates an interval of rows.

Example:

>>> tab.window(Over
>>>         .partition_by(col('a'))
>>>         .order_by(col('proctime'))
>>>         .preceding(row_interval(4))
>>>         .following(CURRENT_ROW)
>>>         .alias('w'))

Parameters

rows – the number of rows

New in version 1.12.0.