spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject spark git commit: [SPARK-6998][MLlib] Make StreamingKMeans 'Serializable'
Date Mon, 20 Apr 2015 03:34:07 GMT
Repository: spark
Updated Branches:
  refs/heads/branch-1.3 1d6e3328d -> 1526f9c29


[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'

(cherry picked from commit fa73da024000386eecef79573e8ac96d6f05b2c7)
Signed-off-by: Reynold Xin <rxin@databricks.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/1526f9c2
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/1526f9c2
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/1526f9c2

Branch: refs/heads/branch-1.3
Commit: 1526f9c298cc06b62802dd1745efc53e8d29e529
Parents: 1d6e332
Author: zsxwing <zsxwing@gmail.com>
Authored: Sun Apr 19 20:33:51 2015 -0700
Committer: Reynold Xin <rxin@databricks.com>
Committed: Sun Apr 19 20:34:04 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/1526f9c2/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


Mime
View raw message