pairRDD1 = sc. parallelize([("spark",1),("spark",2),("hadoop",3),("hadoop",5)]) pairRDD2 = sc.parallelize([("spark","fast")]) pairRDD1.join(pairRDD2) 上述语句执行以后,pairRDD1这个RDD中所包含的元素是
选项:
A:(“spark”,(3,”fast”)), (“spark”,(5,”fast”))
B:(“spark”,(1,”fast”)), (“spark”,(2,”fast”))
C:(“hadoop”,(3,”fast”)), (“hadoop”,(5,”fast”))
D:(“hadoop”,(2,”fast”)), (“hadoop”,(1,”fast”))
发布时间:2024-06-18 05:54:09