diff --git a/flink-python/pyflink/table/expression.py b/flink-python/pyflink/table/expression.py index c3b8f1b659111d..c35106cd4fea24 100644 --- a/flink-python/pyflink/table/expression.py +++ b/flink-python/pyflink/table/expression.py @@ -836,6 +836,10 @@ def collect(self) -> 'Expression': def array_agg(self) -> 'Expression': return _unary_op("arrayAgg")(self) + @property + def mode_agg(self) -> 'Expression': + return _unary_op("modeAgg")(self) + def alias(self, name: str, *extra_names: str) -> 'Expression[T]': """ Specifies a name for an expression i.e. a field.