Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21024#discussion_r180387495
--- Diff: python/pyspark/sql/functions.py ---
@@ -2080,6 +2080,21 @@ def size(col):
return Column(sc._jvm.functions.size(_to_java_column(col)))
+@since(2.4)
+def array_max(col):
+ """
+ Collection function: returns the maximum value of the array.
+
+ :param col: name of column or expression
+
+ >>> df = spark.createDataFrame([([2, 1, 3],),([None, 10, -1],)],
['data'])
--- End diff --
quick nit `,(` ->`, (`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
