擅长:python、mysql、java
<blockquote>
<p>PS: I'm able to perform the same task using simple lambda expression!</p>
</blockquote>
<p>这是做你想做的事的一个完全有效的方法。在</p>
<pre><code>rdd.map(lambda x : (x[1], x[0])).collect()
</code></pre>
<p><code>def</code>方法只是简单地将<code>lambda</code>替换为<code>def</code>,并添加一个返回,而不是在其间添加另一个</em>函数。在</p>
^{pr2}$
<p>要更直观地查看它,请使用Scala方法</p>
<pre><code>rdd.map(_ => swap(_))
</code></pre>
<p>变成</p>
<pre><code>rdd.map(swap)
</code></pre>
<p>其中map参数(单个RDD记录)隐式传递给只接受一个参数的函数</p>