We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2086bdc commit ea22ec8Copy full SHA for ea22ec8
mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala
@@ -17,10 +17,9 @@
17
18
package org.apache.spark.mllib.clustering
19
20
-import breeze.linalg.{Vector => BV}
21
-
22
import scala.reflect.ClassTag
23
-import scala.util.Random._
+
+import breeze.linalg.{Vector => BV}
24
25
import org.apache.spark.annotation.DeveloperApi
26
import org.apache.spark.Logging
@@ -29,6 +28,7 @@ import org.apache.spark.rdd.RDD
29
28
import org.apache.spark.SparkContext._
30
import org.apache.spark.streaming.dstream.DStream
31
import org.apache.spark.streaming.StreamingContext._
+import org.apache.spark.util.Utils
32
33
/**
34
* :: DeveloperApi ::
0 commit comments