hadoop手机流量统计分区partitioner

img

img


问题是
**在FlowDriver驱动类中，增加如下设置：
// 设置自定义的分区器
job.setPartitionerClass(FlowPartitioner.class);
// 同时指定相应数量的ReduceTask
job.setNumReduceTasks(5);
为什么是这样子的？