diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-04-19 20:33:51 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-04-19 20:33:51 -0700 |
| commit | fa73da024000386eecef79573e8ac96d6f05b2c7 (patch) | |
| tree | 0570eabc9e6cb7dce2f2b11770a53b5fc0624af1 /mllib/src | |
| parent | 0424da68d4c81dc3a9944d8485feb1233c6633c4 (diff) | |
| download | spark-fa73da024000386eecef79573e8ac96d6f05b2c7.tar.gz spark-fa73da024000386eecef79573e8ac96d6f05b2c7.tar.bz2 spark-fa73da024000386eecef79573e8ac96d6f05b2c7.zip | |
[SPARK-6998][MLlib] Make StreamingKMeans 'Serializable'
If `StreamingKMeans` is not `Serializable`, we cannot do checkpoint for applications that using `StreamingKMeans`. So we should make it `Serializable`.
Author: zsxwing <zsxwing@gmail.com>
Closes #5582 from zsxwing/SPARK-6998 and squashes the following commits:
67c2a14 [zsxwing] Make StreamingKMeans 'Serializable'
Diffstat (limited to 'mllib/src')
| -rw-r--r-- | mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala | 2 |
1 files changed, 1 insertions, 1 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 f483fd1c7d..d4606fda37 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 @@ -165,7 +165,7 @@ class StreamingKMeansModel( class StreamingKMeans( var k: Int, var decayFactor: Double, - var timeUnit: String) extends Logging { + var timeUnit: String) extends Logging with Serializable { def this() = this(2, 1.0, StreamingKMeans.BATCHES) |