No self-introduction
Loading
Profile
Follow
codes (1)
K-Means algorithms MapReduce
4.0
public class KmeansMapper extends MapReduceBase implements
Mapper<LongWritable, Text, IntWritable, DoubleArrayWritable> {
// one coodinate(data)
private List<DoubleWritable> coordinate = new ArrayList<DoubleWritable>();
private BasicKMeansTool basicKmeans = new BasicKMeansTool();
public void map(LongWritable key, Text value,
OutputCollector<IntWritable, DoubleArrayWritable> midoutput,
Reporter arg3) throws IOException {
// TODO Auto-generated method stub
String line = value.toString();
String[] dataList = line.split(",");
List<DoubleWritable> distances = null;
StringTokenizer itr;
for (int i = 0; i < dataList.length; i++) {
itr = new StringTokenizer(dataList[i]);
coordinate = new ArrayList<DoubleWritable>();
while (itr.hasMoreTokens()) {
DoubleWritable attribut = new DoubleWritable(Double.valueOf(itr
Vincent_lijianpeng 0 0
1
No more~
Follows0
Fans0