网站介绍:文章浏览阅读1.2k次。这个场景的前提是:比如一大批手机号码 需要分区,就是确定那个号码是那个省份的,所以在Maptask阶段是要把所有的省份的号码全部放在一个Map里面,然后提交给reducetask去处理,但是默认的是一个reducetask。 这时候就需要重写Partitioner的方法实现Maptask的去处。package cn.itcast.bigdata.mr.provinceflow;import java_partitioner(string stepname, partitioner partitioner)
- 链接地址:https://blog.csdn.net/Pan_Mars/article/details/66978999
- 链接标题:关于Partitioner(自定义partitioner编程实现数据自定义分区处理)_partitioner(string stepname, partitioner partition-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:2983
- 网站标签:partitioner(string stepname partitioner partitioner)