欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

spark dataframe 將一列展開,把該列所有值都變成新列的方法

 更新時(shí)間:2019年01月29日 11:39:19   作者:Nougats  
今天小編就為大家分享一篇spark dataframe 將一列展開,把該列所有值都變成新列的方法,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧

The original dataframe

spark dataframe 將一列展開,把該列所有值都變成新列

需求:hour代表一天的24小時(shí),現(xiàn)在要將hour列展開,每一個(gè)小時(shí)都作為一個(gè)列

實(shí)現(xiàn):

val pivots = beijingGeoHourPopAfterDrop.groupBy("geoHash").pivot("hour").sum("countGeoPerHour").na.fill(0)

并且統(tǒng)計(jì)了對應(yīng)的countGeoPerHour的和,如果有些行沒有這個(gè)新列對應(yīng)的數(shù)據(jù),將用null填充

The new dataframe

spark dataframe 將一列展開,把該列所有值都變成新列

以上這篇spark dataframe 將一列展開,把該列所有值都變成新列的方法就是小編分享給大家的全部內(nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。

相關(guān)文章

最新評論