add to python

snuyanzin · Mar 6, 2024 · 280dc61 · 280dc61
1 parent 964db23
commit 280dc61
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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.