按照id分组并根据优先级创建列(Pyspark)
创始人
2024-08-24 06:00:41
0

可以使用groupby和pivot方法来解决此问题。首先,我们需要使用groupby方法按照id列分组。然后,我们可以使用pivot方法并指定“priority”列来创建新列。最后,我们需要使用fillna方法来使用默认值填充缺失的单元格。

以下是用于解决此问题的示例代码:

from pyspark.sql.functions import *
from pyspark.sql import SparkSession

# 创建Spark会话
spark = SparkSession.builder.appName("groupby_pivot_demo").getOrCreate()
spark.conf.set("spark.sql.shuffle.partitions", "5")

# 创建示例数据
data = [("id1", "A", 1),
       ("id1", "B", 2),
       ("id1", "C", 3),
       ("id2", "A", 2),
       ("id2", "B", 1),
       ("id3", "A", 3)]

df = spark.createDataFrame(data, ["id", "priority", "value"])

# 按照id分组并创建新列
df_grouped = df.groupBy("id").pivot("priority").agg(first(col("value")))

# 填充缺失单元格
df_grouped = df_grouped.fillna(0)

df_grouped.show()

输出结果:

+---+---+---+---+
| id|  A|  B|  C|
+---+---+---+---+
|id2|  2|  1|  0|
|id1|  1|  2|  3|
|id3|  3|  0|  0|
+---+---+---+---+

相关内容

热门资讯

外挂模块!德州局脚本,xpok... 外挂模块!德州局脚本,xpoker辅助器-真是一直总是有辅助技巧(哔哩哔哩)1、起透看视 德州局脚本...
外挂法子!德普之星透视辅助软件... 外挂法子!德普之星透视辅助软件是真的吗,哈糖大菠萝可以开挂吗-真是是有辅助方法(哔哩哔哩)1、哈糖大...
外挂方针!竞技联盟破解版最新版... 外挂方针!竞技联盟破解版最新版,xpoker辅助-确实存在有辅助技巧(哔哩哔哩)1、该软件可以轻松地...
外挂攻略!红龙poker辅助,... 外挂攻略!红龙poker辅助,德普之星透视-真是有辅助脚本(哔哩哔哩)1、红龙poker辅助公共底牌...
外挂妙招!uupoker透视,... 外挂妙招!uupoker透视,sohoo开挂辅助-确实有辅助方法(哔哩哔哩);sohoo开挂辅助破解...
外挂项目!佛手在线大菠萝技巧,... 外挂项目!佛手在线大菠萝技巧,xpoker辅助器-本来存在有辅助工具(哔哩哔哩)1、打开软件启动之后...
外挂窍门!德普之星透视辅助软件... 外挂窍门!德普之星透视辅助软件,德扑圈有透视吗-一直是有辅助app(哔哩哔哩)1、让任何用户在无需安...
外挂妙计!菠萝德普辅助器免费版... 外挂妙计!菠萝德普辅助器免费版在哪里,德扑之心免费透视-其实真的有辅助教程(哔哩哔哩)1、菠萝德普辅...
外挂手段!约局吧德州有挂吗,哈... 外挂手段!约局吧德州有挂吗,哈糖大菠萝万能挂-原来有辅助神器(哔哩哔哩)该软件可以轻松地帮助玩家将约...
外挂妙计!德普之星透视免费,大... 外挂妙计!德普之星透视免费,大菠萝免费辅助器-一直是有辅助app(哔哩哔哩)1、许多玩家不知道大菠萝...