Revision 48701
Added by Sandro La Bruzzo over 6 years ago
| DNGFKeyPartitioner.java | ||
|---|---|---|
| 10 | 10 |
|
| 11 | 11 |
@Override |
| 12 | 12 |
public int getPartition(DNGFKey key, ImmutableBytesWritable val, int numPartitions) {
|
| 13 |
return Math.abs(key.getId().hashCode() % numPartitions); |
|
| 13 |
final int res = Math.abs(key.getId().hashCode() % numPartitions); |
|
| 14 |
|
|
| 15 |
return res; |
|
| 16 |
|
|
| 17 |
|
|
| 14 | 18 |
} |
| 15 | 19 |
|
| 16 | 20 |
} |
Also available in: Unified diff
Upgraded incremental harvesting and other stuff