Apache Spark Mlib

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 (1.5.2) jar，而且它也是在MLlib中定义的。

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

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;