2024-09-29 01:30:01 发布
网友
我需要创建一个PairRDD(draft\u id),其中key是项目的标识符,value是通过split方法获得的所有字段。我们有rdd草案
PairRDD
key
value
split
rdd
draft.take(3).foreach(println) [Ljava.lang.String;@302bf7bb [Ljava.lang.String;@3128929f [Ljava.lang.String;@30037ad7
您需要调用mapToPair函数,该函数返回一个元组 例如,在python中:
def myMap2pair(element): key = element.getKey() value = element.getValue() return key, value draftKV = draft.map(myMap2pair)
您需要调用mapToPair函数,该函数返回一个元组 例如,在python中:
相关问题 更多 >
编程相关推荐