Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/19307#discussion_r140210945
--- Diff: core/src/main/scala/org/apache/spark/rdd/DoubleRDDFunctions.scala
---
@@ -128,9 +128,9 @@ class DoubleRDDFunctions(self: RDD[Double]) extends
Logging with Serializable {
}
// Compute the minimum and the maximum
val (max: Double, min: Double) = self.mapPartitions { items =>
- Iterator(items.foldRight(Double.NegativeInfinity,
- Double.PositiveInfinity)((e: Double, x: (Double, Double)) =>
- (x._1.max(e), x._2.min(e))))
+ Iterator(
+ items.foldRight((Double.NegativeInfinity, Double.PositiveInfinity)
--- End diff --
More warnings about auto converting 2 args to a single tuple arg
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
