楼主产生这个问题,是因为对于分区的本质还没有认识清楚。
分区是根据分区函数来的,
比如:
这个分区函数是
public class HashPartition(K,V)extends Partitioner<K,V>
{
publice int getPartition(...)
{
函数实现
}
}
比如:随机分配,那么就返回一个随机数目
比如
public class HashPartition(K,V)extends Partitioner<K,V>
{
publice int getPartition(...)
{
return new Random().nextInt();
}
}
这样就是实现了reduce的随机
如果想按照奇偶数
public class HashPartition(K,V)extends Partitioner<K,V>
{
publice int getPartition(...)
{
//函数实现
if(K%2=0)
return K%2;
}
.....
}