infix operator style fix

jkbradley · Oct 9, 2014 · 4b6e777 · 4b6e777
1 parent 4391d3b
commit 4b6e777
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/core/src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala b/core/src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala
@@ -85,8 +85,8 @@ class AsyncRDDActions[T: ClassTag](self: RDD[T]) extends Serializable with Loggi
             numPartsToTry = partsScanned * 4
           } else {
             // the left side of max is >=1 whenever partsScanned >= 2
-            numPartsToTry = ((1.5 * num * partsScanned / results.size).toInt - partsScanned) max 1
-            numPartsToTry = numPartsToTry min (partsScanned * 4) 
+            numPartsToTry = Math.max((1.5 * num * partsScanned / results.size).toInt - partsScanned, 1)
+            numPartsToTry = Math.min(numPartsToTry, partsScanned * 4) 
           }
         }
 

diff --git a/core/src/main/scala/org/apache/spark/rdd/RDD.scala b/core/src/main/scala/org/apache/spark/rdd/RDD.scala
@@ -1086,8 +1086,8 @@ abstract class RDD[T: ClassTag](
           numPartsToTry = partsScanned * 4
         } else {
           // the left side of max is >=1 whenever partsScanned >= 2
-          numPartsToTry = ((1.5 * num * partsScanned / buf.size).toInt - partsScanned) max 1
-          numPartsToTry = numPartsToTry min (partsScanned * 4) 
+          numPartsToTry = Math.max((1.5 * num * partsScanned / buf.size).toInt - partsScanned, 1)
+          numPartsToTry = Math.min(numPartsToTry, partsScanned * 4) 
         }
       }