| 1 |
46317
|
claudio.at
|
package eu.dnetlib.data.mapreduce.hbase.dedup.kv;
|
| 2 |
46275
|
claudio.at
|
|
| 3 |
|
|
import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
|
| 4 |
|
|
import org.apache.hadoop.mapreduce.Partitioner;
|
| 5 |
|
|
|
| 6 |
|
|
/**
|
| 7 |
|
|
* Created by claudio on 13/03/2017.
|
| 8 |
|
|
*/
|
| 9 |
46317
|
claudio.at
|
public class DNGFKeyPartitioner extends Partitioner<DNGFKey, ImmutableBytesWritable > {
|
| 10 |
46275
|
claudio.at
|
|
| 11 |
|
|
@Override
|
| 12 |
46317
|
claudio.at
|
public int getPartition(DNGFKey key, ImmutableBytesWritable val, int numPartitions) {
|
| 13 |
|
|
return Math.abs(key.getId().hashCode() % numPartitions);
|
| 14 |
46275
|
claudio.at
|
}
|
| 15 |
|
|
|
| 16 |
|
|
}
|