pyflink.table.window.Over.partition_by#
- classmethod Over.partition_by(*partition_by: Union[str, pyflink.table.expression.Expression]) pyflink.table.window.OverWindowPartitioned [source]#
Partitions the elements on some partition keys.
Each partition is individually sorted and aggregate functions are applied to each partition separately.
- Parameters
partition_by – List of field references.
- Returns
An over window with defined partitioning.