回答情况：
提问时间：
问题标签：
我已经在spark中使用sqlcontext进行了一次转换，但我只想使用Spark Data frame来编写相同的查询。此查询包含join操作和SQL的case语句。sql查询编写如下： "CASE "
"WHEN (a.Quantity_Sold IS NULL) THEN b.Quantity_Sold "
浏览 0提问于2020-10-18得票数 0
1回答
如何实现分组spark-dataframe的密钥？pyspark.sql.group.GroupedData对象包括什么？
浏览 0修改于2018-05-12得票数 0
回答已采纳
我有一个名为spark-dataframe的输入df|Main_CustomerID| P1| P2| P3|Total_Count我需要创建一个名为spark-dataframe的新frequencyTable，如下所示，
+---------------+------------------+---+--------------
浏览 0提问于2018-06-29得票数 0
回答已采纳
我的输入spark-dataframe名为df，|Main_CustomerID| P1| P2| P3|
+---------
浏览 0提问于2018-07-02得票数 1
回答已采纳
我有一个名为spark-dataframe freq的输入|Main_CustomerID| A1| A2| A3|
浏览 0提问于2018-07-13得票数 0
回答已采纳
当我试图在spark-dataframe上映射这个函数时，我得到了以下错误 #.....TypeError
浏览 1修改于2017-09-08得票数 2
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号