Spark MLlib之KMeans代码,Spark代码库,德仔网

代码语言

代码分类

【Spark】 Spark MLlib之KMeans

作者:皓云 / 发布于2017/5/22/ 571

K选择是 K-means 算法的关键，Spark MLlib 在 KMeansModel 类里提供了 computeCost 方法，该方法通过计算所有数据点到其最近的中心点的平方和来评估聚类的效果。一般来说，同样的迭代次数和算法跑的次数，这个值越小代表聚类的效果越好。但是在实际情况下，我们还要考虑到聚类结果的可解释性，不能一味的选择使 computeCost 结果值最小的那个 K。

import org.apache.spark.SparkConf;  
import org.apache.spark.api.java.JavaRDD;  
import org.apache.spark.api.java.JavaSparkContext;  
import org.apache.spark.api.java.function.Function;  
import org.apache.spark.mllib.clustering.KMeans;  
import org.apache.spark.mllib.clustering.KMeansModel;  
import org.apache.spark.mllib.linalg.Vector;  
import org.apache.spark.mllib.linalg.Vectors;  
  
public class SparkMLlibKMeans {  
  
    public static void main(String[] args) {  
  
        SparkConf conf = new SparkConf().setAppName("K-means Example");  
        JavaSparkContext sc = new JavaSparkContext(conf);  
  
        // Load and parse data  
        String path = "file:///data/hadoop/spark-2.0.0-bin-hadoop2.7/data/mllib/kmeans_data.txt";  
        JavaRDD<String> data = sc.textFile(path);  
        JavaRDD<Vector> parsedData = data.map(new Function<String, Vector>() {  
            public Vector call(String s) {  
                String[] sarray = s.split(" ");  
                double[] values = new double[sarray.length];  
                for (int i = 0; i < sarray.length; i++)  
                    values[i] = Double.parseDouble(sarray[i]);  
                return Vectors.dense(values);  
            }  
        });  
        parsedData.cache();  
          
        // Cluster the data into two classes using KMeans  
        int numIterations = 20;  
        for (int numClusters = 1; numClusters <= 6; numClusters++) {//k值  
          KMeansModel clusters = KMeans.train(parsedData.rdd(), numClusters,  
                numIterations);  
        // Evaluate clustering by computing Within Set Sum of Squared Errors  
          double WSSSE = clusters.computeCost(parsedData.rdd());  
          System.out.println("k=" + numClusters+ " Within Set Sum of Squared Errors = " + WSSSE);  
          Vector[] vs = clusters.clusterCenters();  
          int clusteridx = clusters.predict(Vectors.dense(0.2,0.2,0.2));  
          System.out.println("(0.2,0.2,0.2) is cluster " + clusteridx);  
          for (Vector v : vs) {  
             System.out.println("cluser center=" + v);  
          }  
        }  
        sc.close();  
          
    }  
  
}

试试其它关键字

　KMeans　

同语言下

可能有用的

皓云贡献的其它代码(13)