大數據實戰手冊-開發篇之RDD ： 超詳細RDD函數API

2.2 RDD:計算 transform->actionpython 2.2.1 aggregate x = sc.parallelize([2,3,4], 2)[Task不能跨分片，task數爲2] neutral_zero_value = (0,1) # sum: x+0 = x, product: 1*x = x seqOp = (lambda aggregated, el: (aggreg

>>阅读原文<<