如题 对于RDD[(String, Int)] 的rdd3, rdd3.reduceByKey( (a,b) => a+b ) 是如何执行的?
reduceByKey是哪个scala spark中 哪个类的方法?
reduceByKey是哪个scala spark中哪个类的方法?具体是如何执行的??
答案:2 悬赏:0 手机版
解决时间 2021-01-31 14:37
- 提问者网友：趣果有间
- 2021-01-31 09:46
最佳答案
- 五星知识达人网友：人间朝暮
- 2021-01-31 10:32
org.apache.spark.rdd.PairRDDFunctions
记得import org.apache.spark.SparkContext._
记得import org.apache.spark.SparkContext._
全部回答
- 1楼网友：独钓一江月
- 2021-01-31 11:46
如果是spark1的话应该用的是2.10，2的话应该是2.11，具体的到spark安装目录下看一下jars中scala开头的jar包就可以了
我要举报
如以上问答信息为低俗、色情、不良、暴力、侵权、涉及违法等信息，可以点下面链接进行举报！
大家都在看
推荐资讯