这在 Python 2.7 中有效，但在 Python 3.5 中它返回
SyntaxError: invalid syntax.
我不确定这是否与我在另一篇文章中读到的“元组解包”已从 Python 3 中删除这一事实有关，或者是另一个问题。
rddInverted = rdd.map(lambda (x,y): (y,x))
最佳答案
尝试这样的事情:
rddInverted = rdd.map(lambda x: (x[1], x[0]))
希望能成功
关于python - 如何在 Python 3 pyspark 中反转 RDD 中的键和值？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38569052/