Skip to content

Commit fa73da0

Browse files
zsxwingrxin
authored andcommitted
[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 <[email protected]> Closes #5582 from zsxwing/SPARK-6998 and squashes the following commits: 67c2a14 [zsxwing] Make StreamingKMeans 'Serializable'
1 parent 0424da6 commit fa73da0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ class StreamingKMeansModel(
165165
class StreamingKMeans(
166166
var k: Int,
167167
var decayFactor: Double,
168-
var timeUnit: String) extends Logging {
168+
var timeUnit: String) extends Logging with Serializable {
169169

170170
def this() = this(2, 1.0, StreamingKMeans.BATCHES)
171171

0 commit comments

Comments
 (0)