单项选择题
val rdd=sc.parallelize(1to10).filter(_%2==0)rdd.collect上述代码的执行结果为()
A.Array(1,2,3,4,5,6,7,8,9,10) B.Array(1,3,5,7,9) C.Array(2,4,6,8,10) D.Array(1,10)
单项选择题 val rdd=sc.parallelize(List(("Tom",2),("Lee",5),("Lee",6),(“Tom”,7)))rdd.reduceByKey((x,y)=>x+y).collect上述代码的执行结果为()
单项选择题 配置Standalone模式下的Spark集群,Worker节点需要在conf文件夹下的哪个文件中指明()
单项选择题 MapReduce中的task是以()方式维护的