代碼下載

from pyspark import SparkContextif __name__ == "__main__":sc = SparkContext('local', 'word_count')nums = sc.parallelize([1, 2, 3, 4, 5, 6, 7, 8, 9, 10])sum_count = nums.map(lambda x: (x, 1)).fold((0,0), (lambda x, y: (x[0]+y[0], x[1]+y[1])))average = sum_count[0] / float(sum_count[1]) print(average)

總結(jié)

以上是生活随笔為你收集整理的pyspark github算例 计算平均数的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。