Partitioner

使用自定义partitioner来处理手机上网日志信息 为什么要使用分区?   1.根据业务需要,产生多个输出文件   2.多个reduce任务在运行,提高整体job的运行效率 1 package partitioner; 2 3 import java.io.DataInput; 4 import java.io.DataOutput; 5 import java.io.I
相关文章
相关标签/搜索