Python中文网 - 问答频道, 解决您学习工作中的Python难题和Bug
Python常见问题
我正在用python编写一个从kafka数据流获取RDD的脚本。然后我想把RDD分解并执行一个配置单元查询。 为此，我使用以下代码
recommendationdataset = parsedStream.map(lambda (v): (v.get("CustomerId"))).foreachRDD(generateRecommendation)
然后从GenerateRecommension中调用配置单元查询。 是否可以在这个命令中执行配置单元查询而不必调用foreachrdd，然后调用函数？我知道火花和Python。在
^{pr2}$Tags： kafkalambda代码脚本mapget数据流单元
热门问题
- 将Pandas数据帧转换为PyTorch张量？
- 将Pandas数据帧转换为scipy稀疏矩阵
- 将Pandas数据帧转换为Spark Datafram时出现问题
- 将pandas数据帧转换为spark DataFram时出错
- 将Pandas数据帧转换为spark datafram时收到错误
- 将Pandas数据帧转换为Spark数据帧
- 将Pandas数据帧转换为Tensorflow数据
- 将Pandas数据帧转换为tkinter obj
- 将pandas数据帧转换为XML
- 将Pandas数据帧转换为值sql语句
- 将pandas数据帧转换为元组
- 将pandas数据帧转换为元组列表
- 将pandas数据帧转换为元组列表并删除所有pandas数据类型
- 将pandas数据帧转换为具有头和数据类型的numpy数组
- 将pandas数据帧转换为内存中的拼花地板，并将其加载到Python中的Hadoop中
- 将pandas数据帧转换为内存中类似文件的对象？
- 将Pandas数据帧转换为内存功能（&F）
- 将pandas数据帧转换为列表列表
- 将pandas数据帧转换为列表列表以输入到RNN
- 将Pandas数据帧转换为单行DataFram
热门文章
- Python覆盖写入文件
- 怎样创建一个 Python 列表？
- Python3 List append()方法使用
- 派森语言
- Python List pop()方法
- Python Django Web典型模块开发实战
- Python input() 函数
- Python3 列表(list) clear()方法
- Python游戏编程入门
- 如何创建一个空的set?
- python如何定义(创建)一个字符串
- Python标准库 [The Python Standard Library by Ex
- Python网络数据爬取及分析从入门到精通（分析篇）
- Python3 for 循环语句
- Python List insert() 方法
- Python 字典(Dictionary) update()方法
- Python编程无师自通 专业程序员的养成
- Python3 List count()方法
- Python 网络爬虫实战 [Web Crawler With Python]
- Python Cookbook（第2版）中文版
目前没有回答
相关问题 更多 >
编程相关推荐