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 關注
- 1702 瀏覽
添加回答
舉報
0/150
提交
取消