改写val res = lines.map(lambda x:x.split(",")).filter(lambda x:x[0]=="Tom")
时间: 2023-06-08 07:05:42 浏览: 155
Spark Graphx Introduction
好的,我了解了。根据您的问题,这是一个对Spark以及Python语言的操作。对于给定的文本行,您想要使用逗号作为分隔符将其拆分,并返回包含名称为Tom的行的列表。改写如下:
```python
res = lines.map(lambda x: x.split(",")).filter(lambda x: x[0] == "Tom").collect()
```
上面的代码将执行以下操作:
1. 使用逗号作为分隔符将每个文本行拆分为字符串列表。
2. 过滤列表,选择第一个元素为“Tom”的行。
3. 将所选行作为列表收集并将其存储在变量“res”中。
希望这可以回答您的问题!
阅读全文