pyflink.table.expressions.row_interval#
- row_interval(rows: int) pyflink.table.expression.Expression [source]#
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.