Skip to content
Snippets Groups Projects
Commit fa73da02 authored by zsxwing's avatar zsxwing Committed by Reynold Xin
Browse files

[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'
parent 0424da68
No related branches found
No related tags found
No related merge requests found
......@@ -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)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment