spark countbykey的结果怎么输出
1 回答
叮当猫咪
TA贡献1776条经验 获得超12个赞
numSplits:来自job.getNumMapTasks(),即在job启动时用org.apache.Hadoop.mapred.JobConf.setNumMapTasks(int n)设置的值,给M-R框架的Map数量的提示。goalSize:是输入总大小与提示Map task数量的比值,即期望每个Mapper处理多少的数据
- 1 回答
- 0 关注
- 1646 浏览
添加回答
举报
0/150
提交
取消