pyflink.table.expression.Expression.over#

Expression.over(alias) → pyflink.table.expression.Expression[source]#

Defines an aggregation to be used for a previously specified over window.

Example:

>>> tab.window(Over
>>>         .partition_by(col('c'))
>>>         .order_by(col('rowtime'))
>>>         .preceding(row_interval(2))
>>>         .following(CURRENT_ROW)
>>>         .alias("w")) \
>>>     .select(col('c'), col('a'), col('a').count.over(col('w')))

New in version 1.12.0.