一块儿学Spark(5) -- 基本rdd 常见的转换和行动操做

1.转换操做python  1.1 通常的元素操做函数 #map 和 flatmap #map接受一个函数，把这个函数用于每一个rdd中的元素 nums = sc.parallelize([1,2,3,4]) squared = nums.map(lambda x:x*x)  #[1,4,9,16] #flatmap也是接受一个函数，把这个函数用于每一个rdd中的元素 并扁平化 line

>>阅读原文<<