spark例子

MAP變換例子: 用map 給英語成績+1分給數學成績-1分函數 flatMap() (1)reduce():並行彙總全部RDD元素spa reduce()參數是一個函數,這個函數有兩個參數(首先會分區(默認分區數量與虛擬機的核心數有關,個人是2),而後每一個分區得出結果最後彙總),兩個參數分別是每次分區後兩個分區的結果3d 執行過程:blog 分區:[(1,2),(3,4)]ip 第一次結果:[
相關文章
相關標籤/搜索