diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-04-19 20:48:36 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-04-19 20:48:36 -0700 |
| commit | c776ee8a6fdcdc463746a815b7686e4e33a874a9 (patch) | |
| tree | 0960f5dcd8e31f205e1b89f292caa5408c0b562c /mllib | |
| parent | d8e1b7b06c499289ff3ce5ec91ff354493a17c48 (diff) | |
| download | spark-c776ee8a6fdcdc463746a815b7686e4e33a874a9.tar.gz spark-c776ee8a6fdcdc463746a815b7686e4e33a874a9.tar.bz2 spark-c776ee8a6fdcdc463746a815b7686e4e33a874a9.zip | |
[SPARK-6979][Streaming] Replace JobScheduler.eventActor and JobGenerator.eventActor with EventLoop
Title says it all.
cc rxin tdas
Author: zsxwing <zsxwing@gmail.com>
Closes #5554 from zsxwing/SPARK-6979 and squashes the following commits:
5304350 [zsxwing] Fix NotSerializableException
e9d3479 [zsxwing] Add blank lines
633e279 [zsxwing] Fix NotSerializableException
e496ace [zsxwing] Replace JobGenerator.eventActor with EventLoop
ec6ec58 [zsxwing] Fix the import order
ce0fa73 [zsxwing] Replace JobScheduler.eventActor with EventLoop
Diffstat (limited to 'mllib')
| -rw-r--r-- | mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala b/mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala index d4606fda37..812014a041 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala @@ -20,8 +20,7 @@ package org.apache.spark.mllib.clustering import scala.reflect.ClassTag import org.apache.spark.Logging -import org.apache.spark.SparkContext._ -import org.apache.spark.annotation.{Experimental, DeveloperApi} +import org.apache.spark.annotation.Experimental import org.apache.spark.mllib.linalg.{BLAS, Vector, Vectors} import org.apache.spark.rdd.RDD import org.apache.spark.streaming.dstream.DStream |