reducebykey和groupbykey的區(qū)別 會不會對窗口函數和updatestatebykey函數?
會不會對窗口函數和updatestatebykey函數?在主示例代碼中,testdata RDD的類型被確定為RDD[(string,int)],然后RDD.rddtordp函數這個隱式類型轉換被轉換
會不會對窗口函數和updatestatebykey函數?
在主示例代碼中,testdata RDD的類型被確定為RDD[(string,int)],然后RDD.rddtordp函數這個隱式類型轉換被轉換成pairddfunctions[string,int],從而得到兩個方法reducebykey和combinebykey。