public void reduce(IntWritable key, Iterable<PointWritable> values, Context context) throws IOException, 
    InterruptedException{
		
		for(PointWritable mwc : values){
			for(String featureKey : mwc.getFeatures().keySet()){
				if(newMeanMap.containsKey(featureKey)){
					newMeanMap.get(featureKey).add(mwc.getFeatures().get(featureKey));				
				}else{
					newMeanMap.put(featureKey, new MutableDouble(mwc.getFeatures().get(featureKey)));
				}
			}
		}
		
		newMeanObject = new PointWritable(newMeanMap);
		newMeanObject.normalize();
		context.write(new Text("xxx"), new Text(newMeanObject.getFeaturesString()));
		
	}