From 651932e70337c1f46f0bec84e44265e4eb1e0e66 Mon Sep 17 00:00:00 2001 From: haoyuan Date: Thu, 9 Feb 2012 13:26:23 -0800 Subject: Format the code as coding style agreed by Matei/TD/Haoyuan --- examples/src/main/scala/spark/examples/SparkKMeans.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'examples') diff --git a/examples/src/main/scala/spark/examples/SparkKMeans.scala b/examples/src/main/scala/spark/examples/SparkKMeans.scala index 3139a0a6e2..a153679ab3 100644 --- a/examples/src/main/scala/spark/examples/SparkKMeans.scala +++ b/examples/src/main/scala/spark/examples/SparkKMeans.scala @@ -54,7 +54,7 @@ object SparkKMeans { while(tempDist > convergeDist) { var closest = data.map (p => (closestPoint(p, kPoints), (p, 1))) - var pointStats = closest.reduceByKey {case ((x1, y1), (x2, y2)) => (x1 + x2, y1+y2)} + var pointStats = closest.reduceByKey {case ((x1, y1), (x2, y2)) => (x1 + x2, y1 + y2)} var newPoints = pointStats.map {pair => (pair._1, pair._2._1 / pair._2._2)}.collect() -- cgit v1.2.3