We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9facbe3 commit ea9877cCopy full SHA for ea9877c
mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala
@@ -62,6 +62,16 @@ import org.apache.spark.streaming.StreamingContext._
62
* This decay fraction can be specified in units of 'points' or 'batches'.
63
* if 'batches', behavior will be independent of the number of points per batch;
64
* if 'points', the expected number of points per batch must be specified.
65
+ *
66
+ * Use a builder pattern to construct a streaming KMeans analysis
67
+ * in an application, like:
68
69
+ * val model = new StreamingKMeans()
70
+ * .setDecayFactor(0.5)
71
+ * .setK(3)
72
+ * .setRandomCenters(5)
73
+ * .trainOn(DStream)
74
75
*/
76
@DeveloperApi
77
class StreamingKMeansModel(
0 commit comments