使用PySpark时Row(r)函数报错NameError，是否需额外导入？

是的，Row属于PySpark SQL模块的类，必须先导入才能使用。

你需要在代码开头添加导入语句：

from pyspark.sql import Row

导入后再运行你的代码：

df = textFile.map(lambda r: Row(r)).collect()

就不会再出现NameError: name 'Row' is not defined的错误了。

内容的提问来源于stack exchange，提问作者notaorb