public class TCPartitioner extends Partitioner<Text, TelBean>{ // 生成的文件 part-00000 part的编号结尾就是int类型的返回值 @Override public int getPartition(Text key, TelBean bean, int arg2) { // TODO Auto-generated method stub // 在此进行分区 // 根据电话号码的不同划分到不同

的分区，可以根据电话号码的前缀、区号等信息来进行分区，比如： String prefix = key.toString().substring(0, 3); // 截取电话号码前三位 if ("136".equals(prefix)) { // 以136开头的电话号码分配到1号分区 return 1 % arg2; // 返回1号分区的编号，arg2为分区总数 } else if ("137".equals(prefix)) { // 以137开头的电话号码分配到2号分区 return 2 % arg2; // 返回2号分区的编号，arg2为分区总数 } else { // 其他电话号码分配到3号分区 return 3 % arg2; // 返回3号分区的编号，arg2为分区总数 } } }

以上是一个Hadoop的自定义分区器例子，根据电话号码的前三位不同，将数据分配到不同的分区中，其中arg2为分区总数，可以根据需要进行调整。在getPartition()方法中，根据电话号码的前缀进行判断，如果是以136开头的电话号码，则分配到1号分区，以137开头的电话号码则分配到2号分区，其他电话号码则分配到3号分区，最终返回对应的分区编号。