java - Apache 星火 Mllib

Question

我正在尝试使用 Spark 的 MLlib 在 Java 上实现 KMeans，我偶然发现了一个问题，那就是，尽管我导入了正确的 jar，但我的编译器无法识别这一行

// Cluster the data into two classes using KMeans
    int numClusters = 2;
    int numIterations = 20;
    KMeansModel clusters = KMeans.train(parsedData.rdd(), numClusters, numIterations);

我得到的错误是:The method train(<RDD> vector, int, int) is undefined for the type KMeans()这没有任何意义，因为我已经下载了最新的 apache MLlib(1.5.2) jar，它也在 Javadoc 中定义。

有什么想法吗？以前有人遇到过这种问题吗？

Answer 1

我遇到了类似的问题，通过导入正确的库解决了这个问题，

import org.apache.spark.mllib.clustering.KMeans;
import org.apache.spark.mllib.clustering.KMeansModel;

代替

import org.apache.spark.ml.clustering.KMeans;
import org.apache.spark.ml.clustering.KMeansModel;