pyflink.table.window.Over.partition_by

classmethod Over.partition_by(*partition_by: pyflink.table.expression.Expression) → pyflink.table.window.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.