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设计】。
组建一个关于书籍、作者、出版社的例子： from django.db import models class Publisher(models.Model): name = m...
如下所示： import pandas as pd file = pd.read_csv('file.csv',iterator=True) while True: chunk...
工作中最常见的配置文件有四种：普通key=value的配置文件、Json格式的配置文件、HTML格式的配置文件以及YMAML配置文件。 这其中以第一种居多，后三种在成熟的开源产品中较为...
本文实例讲述了Python实现将罗马数字转换成普通阿拉伯数字的方法。分享给大家供大家参考，具体如下： 罗马数字，我们在某些电视中或者现实生活中都曾经看到过，近日，学习Python时，也遇...
在做接口自动化的时候，请求数据之前都是JSON格式的，Python有自带的包来解决。最近在做APP的接口，遇到XML格式的请求数据，费了很大劲来解决，解决方式是：接口文档拿到的是XML，...