ClusterSumWritable.java

package it.unipi.hadoop;

import org.apache.hadoop.io.Writable;
import java.io.DataOutput;
import java.io.IOException;
import java.io.DataInput;

public class ClusterSumWritable implements Writable {
    private double[] sumCoordinates;
    private int count;

    public ClusterSumWritable() {
        this(new double[0], 0);
    }

    public ClusterSumWritable(double[] sumCoordinates, int count) {
        this.sumCoordinates = sumCoordinates;
        this.count = count;
    }

    public double[] getSumCoordinates() {
        return sumCoordinates;
    }

    public void setSumCoordinates(double[] d) {
        for (int i = 0; i < sumCoordinates.length; i++) {
            this.sumCoordinates[i] = d[i];
        }
    }

    public int getCount() {
        return count;
    }

    public void setCount(int n) {
        this.count = n;
    }

    @Override
    public void write(DataOutput out) throws IOException {
        out.writeInt(sumCoordinates.length);
        for (double sumCoordinate : sumCoordinates) {
            out.writeDouble(sumCoordinate);
        }
        out.writeInt(count);
    }

    @Override
    public void readFields(DataInput in) throws IOException {
        int length = in.readInt();
        sumCoordinates = new double[length];
        for (int i = 0; i < length; i++) {
            sumCoordinates[i] = in.readDouble();
        }
        count = in.readInt();
    }
}