如何解决将Scala RDD映射函数转换为Pyspark
我正在尝试将以下功能从Scala转换为Pyspark ：：
DF.rdd.map(args => (args(0).toString,args.mkString("|"))).take(5)
为此，我正在执行以下地图功能：
DF.rdd.map(lambda line: ",".join([str(x) for x in line])).take(5)
但是Scala代码为我提供了数组结构，而在Python中却得到了定界的结果。
如何将上述scala代码转换为python？
解决方法
您的Scala代码从args返回2个元素列表。
您的python代码返回逗号连接的字符串
这将返回相同的内容
lambda args: [str(args[0]),"|".join(map(str,args))]
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
