The original dataframe
需求：hour代表一天的24小时，现在要将hour列展开，每一个小时都作为一个列
实现：
val pivots = beijingGeoHourPopAfterDrop.groupBy("geoHash").pivot("hour").sum("countGeoPerHour").na.fill(0)
并且统计了对应的countGeoPerHour的和，如果有些行没有这个新列对应的数据，将用null填充
The new dataframe
以上这篇spark dataframe 将一列展开,把该列所有值都变成新列的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持【听图阁-专注于Python设计】。
关于端口扫描器 端口扫描工具（Port Scanner）指用于探测服务器或主机开放端口情况的工具。常被计算机管理员用于确认安全策略，同时被攻击者用于识别目标主机上的可运作的网络服务。 端...
以下代码比较简单，对python实现ftp上传文件相关知识感兴趣的朋友可以参考下 #encoding=utf8 from ftplib import FTP #加载ftp模块 IP...
1、 自定义菜单 adminx.py class GlobalSetting(object): site_title = u'xxx后台' def kuF_site_menu...
本文实例讲述了python3生成随机数的方法。分享给大家供大家参考。具体实现方法如下： 该实例是根据一本书上看到过一个随机数的小程序，经过自己改动，变为了一个猜数字的小游戏，现在在pyt...
本文实例讲述了Python正则表达式分组概念与用法。分享给大家供大家参考，具体如下： 正则表达式分组 分组就是用一对圆括号“()”括起来的正则表达式，匹配出的内容就表示一个分组。从正则...