耶喽川水 2023-12-08 00:06 采纳率: 33.3%
浏览 3

关于#python#的问题,请各位专家解答!

img

img

def GenreYearSales(sc, spark, df, genre_list):
    result_df = df.select('genre', 'year_of_pub', 'num_of_sales').rdd \
        .filter(lambda v: v.genre in genre_list) \
        .map(lambda v: ((v.genre, int(v.year_of_pub)), int(v.num_of_sales))) \
        .reduceByKey(lambda x, y: x + y) \
        .sortByKey()
    saprk_df = result_df.toDF()
    saprk_df.write.jdbc(url=mysql_url, table="Genre_Year_Sales", mode="overwrite", properties=mysql_properties)

  • 写回答

2条回答 默认 最新

  • CSDN-Ada助手 CSDN-AI 官方账号 2023-12-08 02:07
    关注

    【相关推荐】




    如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^
    评论

报告相同问题?

问题事件

  • 修改了问题 12月8日
  • 创建了问题 12月8日

悬赏问题

  • ¥20 用keil,写代码解决两个问题,用库函数
  • ¥50 ID中开关量采样信号通道、以及程序流程的设计
  • ¥15 U-Mamba/nnunetv2固定随机数种子
  • ¥15 C++行情软件的tick数据如何高效的合成K线
  • ¥15 vba使用jmail发送邮件正文里面怎么加图片
  • ¥15 vb6.0如何向数据库中添加自动生成的字段数据。
  • ¥20 在easyX库下编写C语言扑克游戏跑的快,能实现简单的人机对战
  • ¥15 svpwm波形异常求解答
  • ¥15 STM32——硬件IIC从机通信代码实现
  • ¥15 微生物组数据分析--微生物代谢物