编写一个Pyspark查询，在PACK_IND为“Y”或“N”时计算exploded_qty和imploded_qty。
创始人
2024-12-07 05:02:02
0次
from pyspark.sql.functions import *
# 读入数据
df = spark.read.format("csv").option("header", "true").load("/path/to/file.csv")
# 根据条件计算exploded_qty和imploded_qty
df = df.withColumn("exploded_qty", when(col("PACK_IND")=="Y", col("QTY")*col("NUM_PACK")).otherwise(0))
df = df.withColumn("imploded_qty", when(col("PACK_IND")=="N", col("QTY")/col("NUM_PACK")).otherwise(0))
# 显示结果
df.show()
相关内容
热门资讯
两分钟了解！蜀山四川麻将有挂吗...
两分钟了解！蜀山四川麻将有挂吗，大宝麻将辅助器app，可靠技巧（有挂辅助）；1、该软件可以轻松地帮助...
两分钟了解！衢州都莱辅助器，牌...
两分钟了解！衢州都莱辅助器，牌乐门手机麻将有什么，2025新版技巧（有挂技巧）1、下载好牌乐门手机麻...
五分钟了解！福建十三水软件开发...
五分钟了解！福建十三水软件开发，八闽十三张软件，AI教程（有挂普及）1、超多福利：超高返利，海量正版...
6分钟了解！途乐棋牌这个平台靠...
6分钟了解！途乐棋牌这个平台靠谱吗，中至麻将可以设置输赢吗，必赢方法（有挂脚本）1、操作简单，无需注...
四分钟了解！快玩炸翻天辅助器，...
四分钟了解！快玩炸翻天辅助器，星悦广东麻将有没有挂，普及教程（有挂揭秘）1、星悦广东麻将有没有挂系统...
九分钟了解！掌酷十三张系统规律...
九分钟了解！掌酷十三张系统规律，掌电竞技真的能赢吗，大神讲解（有挂揭秘）；1、玩家可以在掌电竞技真的...
9分钟了解！蛮籽重庆麻将有没有...
9分钟了解！蛮籽重庆麻将有没有挂，八闽十三张有外挂吗，必胜教程（有挂解密）1、上手简单，内置详细流程...
8分钟了解！微信牵手跑得快小程...
8分钟了解！微信牵手跑得快小程序辅助器免费，牌乐门如何拿到好牌，技巧教程（有挂透明）；1、每一步都需...
两分钟了解！老友游戏辅助器，财...
两分钟了解！老友游戏辅助器，财神13张 辅助器，2025新版教程（有挂工具）财神13张 辅助器辅助器...
二分钟了解！新玉海楼茶苑有没有...
二分钟了解！新玉海楼茶苑有没有外 挂，牵手互娱有挂吗，详细教程（有挂普及）小薇（透视辅助）致您一封信...