Point.java

package it.unipi.kurapika.utilities;

import org.apache.hadoop.io.ArrayPrimitiveWritable;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Writable;

import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;

public class Point implements Writable {
	
	private IntWritable dimension;
	private ArrayPrimitiveWritable coordinates;
	private IntWritable numPoints;
	
	public Point() {	// actually used
		dimension = new IntWritable();
		coordinates = new ArrayPrimitiveWritable();
		numPoints = new IntWritable();
	}
	
	public void parse(String values) {	// used
        String[] coords = values.split(" ");
        double[] tmp = new double[coords.length];
        for (int i = 0; i < tmp.length; i++) {
            tmp[i] = Double.parseDouble(coords[i]);
        }

        coordinates.set(tmp);
        dimension.set(coords.length);
        numPoints.set(1);
    }
	
	public double getDistance(Point centroid) {	
		double sum = 0.0;
		double [] thisCoord = (double[])this.coordinates.get();
		double [] centrCoord = (double[])centroid.coordinates.get();
		
        for (int i = 0; i < this.dimension.get(); i++) {
            sum += Math.pow(Math.abs(thisCoord[i] - centrCoord[i]), 2);
        }
        return Math.sqrt(sum);
	}
	
	public void sum(Point p) {
		double [] thisCoord = (double[])this.coordinates.get();
		double [] otherCoord = (double[])p.coordinates.get();
		
		for (int i = 0; i < this.dimension.get(); i++) {
            thisCoord[i] += otherCoord[i];
        }
		
		this.coordinates.set(thisCoord);
		
        this.numPoints.set(this.numPoints.get()+p.numPoints.get());
	}
	
	public void compress() {	
		double [] toUpdateCoord = (double[])coordinates.get();
		
		for(int i=0; i<dimension.get(); i++) {
			toUpdateCoord[i] = toUpdateCoord[i]/(numPoints.get());
		}
		coordinates.set(toUpdateCoord);
		numPoints.set(1);
	}
	
	public void setForSum(int size) {	
		double[] vector = new double[size];
		for (int i=0; i<size; i++) {
			vector[i] = 0.0;
		}
		coordinates.set(vector);
		dimension.set(size);
		numPoints.set(0);
	}
	
	public int getDim() {	
		return dimension.get();
	}
	
	@Override
	public void write(DataOutput out) throws IOException {
		// TODO Auto-generated method stub
		dimension.write(out);
		coordinates.write(out);
		numPoints.write(out);
	}

	@Override
	public void readFields(DataInput in) throws IOException {
		// TODO Auto-generated method stub
		dimension.readFields(in);
		coordinates.readFields(in);
		numPoints.readFields(in);
	}
		
	@Override
    public String toString(){	// used
        String temp = "";
        double [] thisCoord = (double[])this.coordinates.get();
        
        for (int i = 0; i < dimension.get() ; i++)
            temp += thisCoord[i] + " ";
        return temp;
    }
}