擅长:python、mysql、java
<p>这个错误是因为<code>print</code>不是Python 2.6中的函数。</p>
<p>您可以定义执行打印的助手自定义项,或者使用<a href="https://docs.python.org/2/library/__future__.html" rel="noreferrer">__future__</a>库将<code>print</code>视为函数:</p>
<pre><code>>>> from operator import add
>>> f = sc.textFile("README.md")
>>> def g(x):
... print x
...
>>> wc.foreach(g)
</code></pre>
<p>或者</p>
<pre><code>>>> from __future__ import print_function
>>> wc.foreach(print)
</code></pre>
<p>但是,我认为最好使用<code>collect()</code>将RDD内容带回驱动程序,因为<code>foreach</code>在工作节点上执行,并且输出可能不一定出现在驱动程序/shell中(它可能处于<code>local</code>模式,但在集群上运行时不会)。</p>
<pre><code>>>> for x in wc.collect():
... print x
</code></pre>