D-Net

package eu.dnetlib.data.mapreduce.hbase.dedup.fixrelation;

import org.apache.hadoop.hbase.io.ImmutableBytesWritable;

import org.apache.hadoop.mapreduce.Partitioner;

public class KeyPartitioner extends Partitioner<Key, ImmutableBytesWritable> {

    @Override

    public int getPartition(Key key, ImmutableBytesWritable val, int numPartitions) {

        final int res = Math.abs(key.getId().hashCode() % numPartitions);

        return res;

    }

}