package comhuiluczP;import comhuiluczPcenterCenterRandomAdapter;import comhuiluczPclusterKmeansAdapter;import comhuiluczPutilDataUtil;import orgapachehadoopconfConfiguration;import javaioIOException;

package com.huiluczP;

import com.huiluczP.center.CenterRandomAdapter; import com.huiluczP.cluster.KmeansAdapter; import com.huiluczP.util.DataUtil; import org.apache.hadoop.conf.Configuration; import java.io.IOException;

public class KmeansRun { public static void main(String[] args){ String dataName = args[0]; int k = Integer.parseInt(args[1]);

    String centerPath = DataUtil.HDFS_OUTPUT + "/centers.txt";
    String newCenterPath = DataUtil.HDFS_OUTPUT + "/new_centers.txt";
    String dataPath = DataUtil.HDFS_INPUT + "/" + dataName;
    String clusterResultPath = DataUtil.HDFS_OUTPUT + "/kmeans_cluster_result.txt";

    CenterRandomAdapter.createRandomCenter(dataPath, centerPath, k);

    for(int i=0;i<30;i++){
        KmeansAdapter.start(dataPath, centerPath, newCenterPath);
        if(KmeansAdapter.checkStop(centerPath, newCenterPath)) {
            break;
        }
    }
    KmeansAdapter.createClusterResult(dataPath, centerPath, clusterResultPath);
}