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设计】。
最常见的一种形式是的是为一个或者多个参数指定默认值，这会创建一个可以使用比定义时允许的参数更少的参数调用的函数， def ask_ok(prompt, retries=4, remi...
如下所示： 原因1：版本不对，如用环境变量设置的python3.7路径，那么用的就是3.7的pip.exe安装了包。却用的是2.7的python运行 原因2：名称重复，在当前路径下有与i...
本文实例讲述了Python基础学习之基本数据结构。分享给大家供大家参考，具体如下： 前言 相比于PHP，Python同样也是脚本解析语言，所以在使用Python的时候，变量和数据结构相对...
最近项目需要，需要在表创建好之后，初始化一些数据。Django初始化数据的方法有很多，但都需要额外的手动操作，不智能。 看网上有一种方法用post_syncdb信号来初始化数据库，但是我...
在编写python函数时，无意中发现一个问题：python中的变量不能以数字打头，以下函数中定义了一个变量3_num_varchar，执行时报错。 函数如下： def databas...