单项选择题
val rdd=sc.parallelize(List(("Tom",2),("Lee",5),("Lee",6),(“Tom”,7)))rdd.reduceByKey((x,y)=>x+y).collect上述代码的执行结果为()
A.Array((1,2),(3,10))
B.Array((9,“Tom”),(11,“Lee”))
C.Array((“Tom”,9),(“Lee”,11))
D.Array((“Tom”,2,7),(“Lee”,5,6))
点击查看答案&解析
相关考题
-
单项选择题
配置Standalone模式下的Spark集群,Worker节点需要在conf文件夹下的哪个文件中指明()
A.regionserver
B.spark-env.sh
C.spark-defaults.conf
D.slaves -
单项选择题
MapReduce中的task是以()方式维护的
A.进程
B.线程
C.流水线
D.以上都不是 -
单项选择题
Spark中的task分别是以()方式维护的
A.进程
B.线程
C.流水线
D.以上都不是
