如何在Python 3 pyspark中的RDD中反转键和值？

Question

这在Python 2.7中有效，但在Python 3.5中返回

SyntaxError：语法无效。

我不确定这是否与从Python 3中删除“元组拆包”这一事实有关，正如我在另一篇文章中看到的那样，还是另一个问题。

rddInverted = rdd.map(lambda (x,y): (y,x))

Answer 1

尝试这样的事情：

rddInverted = rdd.map(lambda x: (x[1], x[0]))

我希望它能起作用

Answer 2

您的 lambda 函数位于 RDD 的行上，它是一个元组。下面是你想要的。

rddInverted = rdd.map(lambda x: (x[1],x[0]))