Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/18113#discussion_r150391056
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/expressions/javalang/typed.java ---
@@ -74,4 +71,40 @@
public static <T> TypedColumn<T, Long> sumLong(MapFunction<T, Long> f) {
return new TypedSumLong<T>(f).toColumnJava();
}
+
+ /**
+ * Min aggregate function for floating point (double) type.
+ *
+ * @since 2.3.0
+ */
+ public static <T> TypedColumn<T, Double> min(MapFunction<T, Double> f) {
+ return new TypedMinDouble<T>(f).toColumnJava();
+ }
+
+ /**
+ * Min aggregate function for floating point (long, i.e. 64 bit integer)
type.
--- End diff --
I don't think long is a floating point...
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
