一塊兒學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

>>阅读原文<<