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)
关于#python#的问题,请各位专家解答!
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
2条回答 默认 最新
关注 【相关推荐】
- 这有个类似的问题, 你可以参考下: https://ask.csdn.net/questions/7511137
- 这篇博客你也可以参考下:Python实现后端提升性能常用技术组合!
- 您还可以看一下 李彦芹老师的玩转Python图像处理课程中的 让图像做任意运动小节, 巩固相关知识点
- 除此之外, 这篇博客: python 配置文件解析中的 总结 部分也许能够解决你的问题, 你可以仔细阅读以下内容或跳转源博客中阅读:
采用ini配置文件比较简单,并且方便改写配置信息,其次是json配置文件,在后是xml编码配置文件
如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^解决 无用评论 打赏 举报
悬赏问题
- ¥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 微生物组数据分析--微生物代谢物