style correction

avulanov · Jul 14, 2015 · ef95ee2 · ef95ee2
1 parent c446c58
commit ef95ee2
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeans.scala b/mllib/src/main/scala/org/apache/spark/mllib/clustering/KMeans.scala
@@ -209,12 +209,13 @@ class KMeans private (
     val initStartTime = System.nanoTime()
 
     // Only one run is allowed when initialModel is given
-    val numRuns = if (initialModel.nonEmpty){
-      if (runs >1 ) logWarning("Ignoring runs; one run is allowed when initialModel is given.")
+    val numRuns = if (initialModel.nonEmpty) {
+      if (runs > 1) logWarning("Ignoring runs; one run is allowed when initialModel is given.")
       1
-    } else runs
-
-
+    } else {
+      runs
+    }
+
     val centers = initialModel match {
       case Some(kMeansCenters) => {
         Array(kMeansCenters.clusterCenters.map(s => new VectorWithNorm(s)))