如何解决根据列值过滤RDD
物业编号|位置|价格|卧室|浴室
我已使用 :-
将此文件读取为 rdda = sc.textFile("/FileStore/tables/realestate.txt")
现在我需要找到
B.创建一个包含 3 个卧室的 Property ID 的 RDD
c.创建另一个包含至少 2 个浴室的 Property ID 的 RDD
如何在rdd中选择列并根据列值过滤表格。
解决方法
您可以使用 lambda 函数filter RDD：
b = a.filter(lambda r: int(r.split('|')[3]) == 3 if r.split('|')[0] != 'Property ID' else True)
c = a.filter(lambda r: int(r.split('|')[4]) >= 2 if r.split('|')[0] != 'Property ID' else True)
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
