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 374a706 commit 9f7aea9Copy full SHA for 9f7aea9
mllib/src/main/scala/org/apache/spark/mllib/clustering/StreamingKMeans.scala
@@ -243,10 +243,11 @@ class StreamingKMeans(
243
data.mapValues(model.predict)
244
}
245
246
- /** Check whether cluster centers have been initialized.*/
+ /** Check whether cluster centers have been initialized. */
247
def assertInitialized(): Unit = {
248
if (Option(model.clusterCenters) == None) {
249
- throw new IllegalStateException("Initial cluster centers must be set before starting predictions")
+ throw new IllegalStateException(
250
+ "Initial cluster centers must be set before starting predictions")
251
252
253
0 commit comments