当前位置:主页 > 软件编程 > Python代码 >

spark dataframe 将一列展开,把该列所有值都变成新列的方法

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

The original dataframe

spark dataframe 将一列展开,把该列所有值都变成新列

需求:hour代表一天的24小时,现在要将hour列展开,每一个小时都作为一个列

实现:

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

并且统计了对应的countGeoPerHour的和,如果有些行没有这个新列对应的数据,将用null填充

The new dataframe

spark dataframe 将一列展开,把该列所有值都变成新列

您可能感兴趣的文章:

相关文章