You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/04/20 05:34:00 UTC
spark git commit: [SPARK-6998][MLlib] Make StreamingKMeans
'Serializable'
Repository: spark
Updated Branches:
refs/heads/master 0424da68d -> fa73da024
[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 <zs...@gmail.com>
Closes #5582 from zsxwing/SPARK-6998 and squashes the following commits:
67c2a14 [zsxwing] Make StreamingKMeans 'Serializable'
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fa73da02
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fa73da02
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fa73da02
Branch: refs/heads/master
Commit: fa73da024000386eecef79573e8ac96d6f05b2c7
Parents: 0424da6
Author: zsxwing <zs...@gmail.com>
Authored: Sun Apr 19 20:33:51 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Sun Apr 19 20:33:51 2015 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/fa73da02/mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala
----------------------------------------------------------------------
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 f483fd1..d4606fd 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)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org