aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorRaymond Liu <raymond.liu@intel.com>2014-07-09 23:39:29 -0700
committerReynold Xin <rxin@apache.org>2014-07-09 23:39:29 -0700
commit2b18ea9826395177ac2203dbf8eb37c220ab8e67 (patch)
tree92b1bd7ea6a98b983cf6e9935f83141ffab12b0f /examples
parent553c578de1a73a605197c184fc028efcc8dff010 (diff)
downloadspark-2b18ea9826395177ac2203dbf8eb37c220ab8e67.tar.gz
spark-2b18ea9826395177ac2203dbf8eb37c220ab8e67.tar.bz2
spark-2b18ea9826395177ac2203dbf8eb37c220ab8e67.zip
Clean up SparkKMeans example's code
remove unused code Author: Raymond Liu <raymond.liu@intel.com> Closes #1352 from colorant/kmeans and squashes the following commits: ddcd1dd [Raymond Liu] Clean up SparkKMeans example's code
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/scala/org/apache/spark/examples/SparkKMeans.scala5
1 files changed, 0 insertions, 5 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/SparkKMeans.scala b/examples/src/main/scala/org/apache/spark/examples/SparkKMeans.scala
index 4d28e0aad6..79cfedf332 100644
--- a/examples/src/main/scala/org/apache/spark/examples/SparkKMeans.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/SparkKMeans.scala
@@ -17,8 +17,6 @@
package org.apache.spark.examples
-import java.util.Random
-
import breeze.linalg.{Vector, DenseVector, squaredDistance}
import org.apache.spark.{SparkConf, SparkContext}
@@ -28,15 +26,12 @@ import org.apache.spark.SparkContext._
* K-means clustering.
*/
object SparkKMeans {
- val R = 1000 // Scaling factor
- val rand = new Random(42)
def parseVector(line: String): Vector[Double] = {
DenseVector(line.split(' ').map(_.toDouble))
}
def closestPoint(p: Vector[Double], centers: Array[Vector[Double]]): Int = {
- var index = 0
var bestIndex = 0
var closest = Double.PositiveInfinity