在Python Spark中查看RDD的内容？

10 浏览
0 Comments

在Python Spark中查看RDD的内容？

在pyspark中运行一个简单的应用程序。

f = sc.textFile（“README.md”）
wc = f.flatMap（lambda x：x.split（' '））。map（lambda x：（x，1））。reduceByKey（add）

我想使用foreach操作查看RDD的内容：

wc.foreach（print）

这会引发语法错误：

SyntaxError：无效的语法

我错过了什么？

0