pyflink.table.window.Over.partition_by

classmethod Over.partition_by(*partition_by: Expression) → OverWindowPartitioned

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.