[SPARK-7946] DecayFactor wrongly set in StreamingKMeans

MechCoder · MechCoder · commit 8c988c6d0a31 · 2015-05-29T16:28:05.000+05:30
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
@@ -178,7 +178,7 @@ class StreamingKMeans(
 
   /** Set the decay factor directly (for forgetful algorithms). */
   def setDecayFactor(a: Double): this.type = {
-    this.decayFactor = decayFactor
+    this.decayFactor = a
     this
   }
 

Original file line number	Diff line number	Diff line change
`@@ -178,7 +178,7 @@ class StreamingKMeans(`
`178`	`178`
`179`	`179`	`/** Set the decay factor directly (for forgetful algorithms). */`
`180`	`180`	`def setDecayFactor(a: Double): this.type = {`
`181`		`- this.decayFactor = decayFactor`
	`181`	`+ this.decayFactor = a`
`182`	`182`	`this`
`183`	`183`	`}`
`184`	`184`