时间:2021-05-26 08:14:36 | 栏目:Python代码 | 点击:次
The original dataframe

需求:hour代表一天的24小时,现在要将hour列展开,每一个小时都作为一个列
实现:
val pivots = beijingGeoHourPopAfterDrop.groupBy("geoHash").pivot("hour").sum("countGeoPerHour").na.fill(0)
并且统计了对应的countGeoPerHour的和,如果有些行没有这个新列对应的数据,将用null填充
The new dataframe
