单项选择题
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文件夹下的哪个文件中指明()
单项选择题 MapReduce中的task是以()方式维护的
单项选择题 Spark中的task分别是以()方式维护的