Spark 1.3.1 Python ForeachRDD我正在用python编写一个从kafka数据流获取RDD的脚本。然后我想把RDD分解并执行一个配置单元查询。 为此,我使用以下代码 recommendationdataset = parsedStre ...2024-06-09 已阅读: n次