partition分区
//默认
public class HashPartitioner<K,V> extends Partitioner<k,v>{
public int getPartition(K key, V value, int numReduceTasks){
return (key.hashCode() & Integer.MAX_VALUE) % numReduceTasks;
}
}
//自定义
public class PhonenumPartitioner extends Partitioner<Text, FlowBean>{
@Override
public int getPartition(Text key, FlowBean value, int numPartitions){
//1、获取手机号前三位
String phoneNum = key.toString().substring(0,3);
//2、分区
int partitioner = 4;
if("135".equals(phoneNum)){
return 0;
}else if("137".equals(phoneNum)){
return 1;
}else ("138".equals(phoneNum)){
return 2;
}
return partitioner;
}
}
Diriver类{
job.setPartitionerClass(PhonenumPartitioner.class);
job.setNumReduceTask(4); //设置的数量,要大于自定义的时候分区的数量
}