基于MapReduce的Kmeans算法代码及其使用.docx

基于MapReduce的Kmeans算法代码及其使用.docx;;;;.;.;.;.;.;.;.;.;.;.;lassKmeans{//staticList<ArrayList<Double»centers;//staticintK;//staticintdataBeginlndex;lassKmeansMapperextendsMapper<Object,Text,IntWritable,Text>{publicvoidmap(Objectkey,Textvalue,Contextcontext)throwsIOException,InterruptedException{Stringline=;String[]fields=(n,");List<ArrayList<Double»centers=(().get(ncentersPathn));intdataBeginlndex=(context>getConfiguration().get("dtBegIdxPath"));intK=(().get(HKPathn));doubleminDistance=99999999;intcenterindex=K;for(inti=0;i<K;i++){doublecurrentDistance=0;for(intj=dataBeginlndex;j<;j++){doubletl=((i).get(j));doublet2=((fields[j]));currentDistance+=((tl-12)/(tl+t2),2);}(currentDistance,HcurrentDistancen);if(minDistance>currentDistance){minDistance=currentDistance;centerindex=i;}}IntWritablecenterld=newIntWritable(centerIndex+1);Te