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